Skip to main content

Module streaming

Module streaming 

Source
Expand description

Streaming Module

Provides comprehensive streaming support including:

  • SSE (Server-Sent Events) parsing
  • Enhanced message stream handling with delta processing
  • Stream JSON I/O for CLI communication
  • Backpressure control and timeout handling

Re-exports§

pub use message_stream::ContentBlock;
pub use message_stream::DeltaType;
pub use message_stream::EnhancedMessageStream;
pub use message_stream::MessageState;
pub use message_stream::StreamCallbacks;
pub use message_stream::StreamEventType;
pub use message_stream::StreamOptions;
pub use sse::SSEDecoder;
pub use sse::SSEEvent;
pub use sse::SSEStream;
pub use stream_io::AnyStreamMessage;
pub use stream_io::StreamJsonReader;
pub use stream_io::StreamJsonWriter;
pub use stream_io::StreamMessageType;
pub use stream_io::StreamSession;

Modules§

message_stream
Enhanced Message Stream Handler
sse
Server-Sent Events (SSE) Parser
stream_io
Stream JSON I/O