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