Struct AgentRouter 

pub struct AgentRouter<W>
where
    W: AsyncWrite + Unpin + Send,
{ /* private fields */ }

Agent-side router for handling multiplexed streams and request dispatch

Implementations

impl<W> AgentRouter<W>

where W: AsyncWrite + Unpin + Send + 'static,

pub fn new(writer: W) -> Self

Create a new agent router

pub async fn register_handler( &self, request_type: String, handler: Arc<dyn Handler>, )

Register a handler for a specific request type

pub fn shutdown_sender(&mut self) -> Option<Sender<()>>

Get shutdown sender for graceful shutdown

pub async fn route_frame(&self, frame: Frame) -> Result<()>

Route an incoming frame to the appropriate handler

pub async fn start_processing(&mut self) -> Result<()>

Start the request processing loop

pub async fn active_stream_count(&self) -> usize

Get active stream count

pub async fn active_streams(&self) -> Vec<u32>

Get list of active stream IDs