Struct StreamHandler 

pub struct StreamHandler { /* private fields */ }

Stream handler for processing server events

Implementations

impl StreamHandler

pub fn new() -> Self

Create a new stream handler

pub fn set_receiver(&mut self, receiver: UnboundedReceiver<ServerEvent>)

Set event receiver from transport

pub fn on_notification<F>(&self, callback: F)

where F: Fn(Value) + Send + Sync + 'static,

Set notification callback

pub fn on_request<F>(&self, callback: F)

where F: Fn(Value) -> Result<Value, String> + Send + Sync + 'static,

Set request callback

pub fn on_connection_lost<F>(&self, callback: F)

where F: Fn() + Send + Sync + 'static,

Set connection lost callback

pub fn on_error<F>(&self, callback: F)

where F: Fn(String) + Send + Sync + 'static,

Set error callback

pub fn on_heartbeat<F>(&self, callback: F)

where F: Fn() + Send + Sync + 'static,

Set heartbeat callback

pub async fn start(&mut self) -> McpClientResult<()>

Start processing events

pub fn is_active(&self) -> bool

Check if handler is active

Trait Implementations

impl Debug for StreamHandler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamHandler

fn default() -> Self

Returns the “default value” for a type.