streaming

Jan 15, 2026

Changes in this version

+ const DefaultChunkDurationMs

+ const DefaultImageQuality

+ const DefaultTargetFPS

+ func SendImageEndOfStream(ctx context.Context, output chan<- stage.StreamElement) error

+ func SendVideoEndOfStream(ctx context.Context, output chan<- stage.StreamElement) error

+ type ImageStreamer struct

+ TargetFPS float64

+ func NewImageStreamer(targetFPS float64) *ImageStreamer

+ func (s *ImageStreamer) SendFrame(ctx context.Context, data []byte, mimeType string, frameNum int64, ...) error

+ func (s *ImageStreamer) SendFrameWithDimensions(ctx context.Context, data []byte, mimeType string, width, height int, ...) error

+ func (s *ImageStreamer) StreamFramesBurst(ctx context.Context, frames [][]byte, mimeType string, ...) error

+ func (s *ImageStreamer) StreamFramesRealtime(ctx context.Context, frames [][]byte, mimeType string, ...) error

+ type VideoChunk struct

+ Data []byte

+ Duration time.Duration

+ IsKeyFrame bool

+ Timestamp time.Time

+ type VideoStreamer struct

+ ChunkDurationMs int

+ func NewVideoStreamer(chunkDurationMs int) *VideoStreamer

+ func (s *VideoStreamer) SendChunk(ctx context.Context, data []byte, mimeType string, chunkIndex int, ...) error

+ func (s *VideoStreamer) SendChunkWithDimensions(ctx context.Context, data []byte, mimeType string, width, height int, ...) error

+ func (s *VideoStreamer) StreamChunksBurst(ctx context.Context, chunks []VideoChunk, mimeType string, ...) error

+ func (s *VideoStreamer) StreamChunksRealtime(ctx context.Context, chunks []VideoChunk, mimeType string, ...) error

Dec 23, 2025

Changes in this version

+ const DefaultChunkIntervalMs

+ const DefaultChunkSize

+ const DefaultSampleRate

+ var ErrEmptyResponse = errors.New("empty response, likely interrupted")

+ var ErrSessionEnded = errors.New("session ended")

+ func BuildToolResponseElement(result *ToolExecutionResult) stage.StreamElement

+ func DrainStaleMessages(outputChan <-chan stage.StreamElement) (int, error)

+ func ExecuteAndSend(ctx context.Context, executor ToolExecutor, toolCalls []types.MessageToolCall, ...) error

+ func SendEndOfStream(ctx context.Context, inputChan chan<- stage.StreamElement) error

+ func SendToolResults(ctx context.Context, result *ToolExecutionResult, ...) error

+ func WaitForResponse(ctx context.Context, responseDone <-chan error) error

+ type AudioStreamer struct

+ ChunkIntervalMs int

+ ChunkSize int

+ func NewAudioStreamer() *AudioStreamer

+ func (a *AudioStreamer) SendChunk(ctx context.Context, chunk []byte, sampleRate int, ...) error

+ func (a *AudioStreamer) StreamBurst(ctx context.Context, audioData []byte, sampleRate int, ...) error

+ func (a *AudioStreamer) StreamRealtime(ctx context.Context, audioData []byte, sampleRate int, ...) error

+ type ResponseAction int

+ const ResponseActionComplete

+ const ResponseActionContinue

+ const ResponseActionError

+ const ResponseActionToolCalls

+ func ProcessResponseElement(elem *stage.StreamElement, logPrefix string) (ResponseAction, error)

+ func (a ResponseAction) String() string

+ type ResponseCollector struct

+ func NewResponseCollector(config ResponseCollectorConfig) *ResponseCollector

+ func (c *ResponseCollector) Start(ctx context.Context, outputChan <-chan stage.StreamElement, ...) <-chan error

+ type ResponseCollectorConfig struct

+ LogPrefix string

+ ToolExecutor ToolExecutor

+ type ToolExecutionResult struct

+ ProviderResponses []providers.ToolResponse

+ ResultMessages []types.Message

+ type ToolExecutor interface

+ Execute func(ctx context.Context, toolCalls []types.MessageToolCall) (*ToolExecutionResult, error)