@cavi-ai/api-client/core/sse

export declare function combineAbortSignals(a: AbortSignal, b: AbortSignal | undefined): AbortSignal;

export declare function consumeSseStream(body: ReadableStream<Uint8Array>, signal: AbortSignal, onMessage: SseMessageHandler): Promise<void>;

export declare function drainSseMessages(buffer: string, onMessage: SseMessageHandler): string;

export declare function isSseContentType(contentType: string | null | undefined): boolean;

export declare function parseSseBlock(block: string): SseMessage | null;

export type SseMessage = {
    data: string;
    event?: string;
    id?: string;
    retry?: number;
};

export type SseMessageHandler = (message: SseMessage) => void;

export declare function takeNextSseBlock(buffer: string): {
    block: string;
    rest: string;
} | null;