Struct StreamManagerNotificationBroadcaster 

pub struct StreamManagerNotificationBroadcaster { /* private fields */ }

StreamManager-backed notification broadcaster that bridges events to SSE

This implementation converts ALL MCP notification types to proper JSON-RPC format and forwards them to StreamManager for SSE delivery

Implementations

impl StreamManagerNotificationBroadcaster

pub fn new(stream_manager: Arc<StreamManager>) -> Self

Create new broadcaster that forwards events to StreamManager

Trait Implementations

impl NotificationBroadcaster for StreamManagerNotificationBroadcaster

fn send_progress_notification<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, notification: ProgressNotification, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a progress notification (notifications/progress) Used for long-running operations to show progress updates

fn send_message_notification<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, notification: LoggingMessageNotification, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a logging message notification (notifications/message) Used to send log messages with different levels (debug, info, warning, error)

fn send_resource_updated_notification<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, notification: ResourceUpdatedNotification, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send resource updated notification (notifications/resources/updated) Notifies that a specific resource has been updated

fn send_resource_list_changed_notification<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, notification: ResourceListChangedNotification, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send resource list changed notification (notifications/resources/list_changed) Notifies that the resource list has changed (added/removed resources)

fn send_tool_list_changed_notification<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, notification: ToolListChangedNotification, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send tool list changed notification (notifications/tools/list_changed) Notifies that the tool list has changed (added/removed tools)

fn send_prompt_list_changed_notification<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, notification: PromptListChangedNotification, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send prompt list changed notification (notifications/prompts/list_changed) Notifies that the prompt list has changed (added/removed prompts)

fn send_cancelled_notification<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, notification: CancelledNotification, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send cancelled notification (notifications/cancelled) Can be sent by either client or server to cancel a request

fn broadcast_to_all_sessions<'life0, 'async_trait>( &'life0 self, notification: JsonRpcNotification, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Broadcast any JSON-RPC notification to all active sessions (server-wide notifications)

fn send_notification<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, notification: JsonRpcNotification, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send any generic JSON-RPC notification to a specific session