import type { SDKConfig, TaskPayload } from './types/sdk'; import type { TextStream, TextStreamChunk, TextStreamResult } from './types/stream'; export type { TextStream, TextStreamChunk, TextStreamResult }; /** * Parse a single Server-Sent Events line into a `TextStreamChunk`. * * Returns: * - a chunk when the line is a valid `data: {...}` JSON payload * - `null` for comments, the `[DONE]` sentinel, or blank lines (caller skips) * Throws if the SSE payload contains an `error` / `errors` field — the caller * is responsible for propagating that as a `RunwareError` to the consumer. * * Exported for advanced consumers who implement custom SSE handling. Most * users iterate the streams returned by `client.stream()` directly and never * need to call this. */ export declare const parseSseLine: (line: string) => TextStreamChunk | null; export declare const createTextStream: (tasks: TaskPayload[], config: SDKConfig, signal?: AbortSignal, onStart?: () => Promise) => TextStream; //# sourceMappingURL=stream.d.ts.map