Struct StreamManager 

pub struct StreamManager { /* private fields */ }

Enhanced stream manager with resumability support (MCP spec compliant)

Implementations

impl StreamManager

pub fn new(storage: Arc<BoxedSessionStorage>) -> Self

Create new stream manager with session storage backend

pub fn with_config( storage: Arc<BoxedSessionStorage>, config: StreamConfig, ) -> Self

Create stream manager with custom configuration

pub async fn handle_sse_connection( &self, session_id: String, connection_id: ConnectionId, last_event_id: Option<u64>, ) -> Result<Response<UnsyncBoxBody<Bytes, Error>>, StreamError>

Handle SSE connection request with proper resumability

pub async fn unregister_connection( &self, session_id: &str, connection_id: &ConnectionId, )

Remove a connection when it’s closed

pub async fn broadcast_to_session( &self, session_id: &str, event_type: String, data: Value, ) -> Result<u64, StreamError>

Send event to specific session (MCP compliant - ONE connection only)

pub async fn broadcast_to_all_sessions( &self, event_type: String, data: Value, ) -> Result<Vec<String>, StreamError>

Broadcast to all sessions (for server-wide notifications)

pub async fn cleanup_connections(&self) -> usize

Clean up closed connections

pub async fn create_post_sse_stream( &self, session_id: String, response: JsonRpcResponse, ) -> Result<Response<Full<Bytes>>, StreamError>

Create SSE stream for POST requests (MCP Streamable HTTP)

pub async fn get_stats(&self) -> StreamStats

Get statistics about active streams

Trait Implementations

impl Drop for StreamManager

fn drop(&mut self)

Executes the destructor for this type.