CerealChatTransport

export declare class CerealChatTransport<CHUNK = AiSdkStreamChunk> {
    constructor(options: {
        readonly tokenSource: () => Promise<StreamToken>;
        readonly sendUrl: string;
        readonly fetch?: typeof globalThis.fetch;
        readonly headers?: Readonly<Record<string, string>>;
        readonly onError?: (error: unknown) => void;
    });
    sendMessages(input: {
        readonly messages: ReadonlyArray<unknown>;
        readonly abortSignal?: AbortSignal;
        readonly trigger?: string;
        readonly chatId?: string;
        readonly messageId?: string;
    }): Promise<ReadableStream<CHUNK>>;
    reconnectToStream(_input?: {
        readonly chatId?: string;
    }): Promise<ReadableStream<CHUNK>>;
}