Struct PendingRequests 

pub struct PendingRequests { /* private fields */ }

Tracks pending server-to-client requests.

When the server sends a request to the client, it registers a response sender here. When a response arrives, the dispatcher routes it to the correct sender.

Implementations

impl PendingRequests

pub fn new() -> Self

Creates a new pending request tracker.

pub fn next_request_id(&self) -> RequestId

Generates a new unique request ID.

pub fn register(&self, id: RequestId) -> Receiver<Result<Value, JsonRpcError>>

Registers a pending request and returns a receiver for the response.

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

Routes a response to the appropriate pending request.

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

pub fn remove(&self, id: &RequestId)

Removes a pending request (e.g., on timeout or cancellation).

pub fn cancel_all(&self)

Cancels all pending requests with a connection closed error.

Trait Implementations

impl Debug for PendingRequests

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

Formats the value using the given formatter.

impl Default for PendingRequests

fn default() -> Self

Returns the “default value” for a type.