Struct RequestMultiplexer 

pub struct RequestMultiplexer { /* private fields */ }

Request multiplexer for handling bidirectional communication

Tracks pending server→client requests and routes responses

Implementations

impl RequestMultiplexer

pub fn new() -> Self

Create a new request multiplexer

pub fn with_timeout(timeout: Duration) -> Self

Create with custom default timeout

pub fn default_timeout(&self) -> Duration

Get default timeout

pub fn create_pending( &self, method: impl Into<String>, ) -> (String, Receiver<Result<Value, MultiplexerError>>)

Create a new pending request and return the receiver

Returns (request_id, receiver) - the caller should await the receiver

pub fn route_response(&self, response: &JsonRpcResponse) -> bool

Route an incoming response to its pending request

Returns true if the response was routed, false if no matching request found

pub fn is_pending_response(&self, id: &Value) -> bool

Check if a response ID matches a pending request

Used to distinguish client responses from client requests in the message loop

pub fn pending_count(&self) -> usize

Get number of pending requests

pub fn cancel(&self, id: &str)

Cancel a pending request

pub fn cancel_all(&self)

Cancel all pending requests

pub fn cleanup_timed_out(&self, timeout: Duration) -> usize

Clean up timed-out requests

Returns the number of requests that were cleaned up

Trait Implementations

impl Default for RequestMultiplexer

fn default() -> Self

Returns the “default value” for a type.