@conciergus/chat - v0.3.1
    Preparing search index...

    Interface StreamingManagerHook

    interface StreamingManagerHook {
        state: StreamingManagerState;
        startStream: (
            streamId: string,
            stream:
                | AsyncIterable<EnhancedStreamPart, any, any>
                | ReadableStream<EnhancedStreamPart>,
            messageId?: string,
        ) => Promise<void>;
        stopStream: (streamId: string) => void;
        stopAllStreams: () => void;
        isStreamActive: (streamId: string) => boolean;
        getStreamStatus: (
            streamId: string,
        ) => "error" | "completed" | "streaming" | "connecting" | "aborted";
        getStreamProgress: (streamId: string) => number;
        retryStream: (streamId: string) => Promise<void>;
        clearErrors: () => void;
        enablePollingFallback: (messageId: string, endpoint: string) => void;
        disablePollingFallback: (messageId: string) => void;
        onStreamProgress?: (
            streamId: string,
            progress: number,
            tokenCount: number,
        ) => void;
        onStreamComplete?: (streamId: string, finalMessage: UIMessage) => void;
        onStreamError?: (streamId: string, error: Error) => void;
        onConnectionStatusChange?: (
            streamId: string,
            status: "error" | "completed" | "streaming" | "connecting" | "aborted",
        ) => void;
    }
    Index

    Properties

    startStream: (
        streamId: string,
        stream:
            | AsyncIterable<EnhancedStreamPart, any, any>
            | ReadableStream<EnhancedStreamPart>,
        messageId?: string,
    ) => Promise<void>
    stopStream: (streamId: string) => void
    stopAllStreams: () => void
    isStreamActive: (streamId: string) => boolean
    getStreamStatus: (
        streamId: string,
    ) => "error" | "completed" | "streaming" | "connecting" | "aborted"
    getStreamProgress: (streamId: string) => number
    retryStream: (streamId: string) => Promise<void>
    clearErrors: () => void
    enablePollingFallback: (messageId: string, endpoint: string) => void
    disablePollingFallback: (messageId: string) => void
    onStreamProgress?: (
        streamId: string,
        progress: number,
        tokenCount: number,
    ) => void
    onStreamComplete?: (streamId: string, finalMessage: UIMessage) => void
    onStreamError?: (streamId: string, error: Error) => void
    onConnectionStatusChange?: (
        streamId: string,
        status: "error" | "completed" | "streaming" | "connecting" | "aborted",
    ) => void