Struct SessionOutbound 

pub struct SessionOutbound { /* private fields */ }

Per-session outbound-request state: id allocation + response correlation.

The same shape the stdio runtime’s ServerState uses (which now delegates here): plain incrementing numeric ids — JSON-RPC ids are per-sender, so they cannot collide with client-chosen ids — and a oneshot per pending request.

Implementations

impl SessionOutbound

pub fn new() -> Self

Create an empty registry.

pub fn next_id(&self) -> RequestId

Allocate a unique id for a server-initiated request.

pub fn register(&self, id: RequestId) -> Receiver<Response>

Register a pending request, returning the receiver that resolves when the matching response arrives.

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

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

pub fn resolve(&self, response: Response) -> bool

Route an inbound response to the request waiting for it. Returns false when no pending request matches (late or unknown id — the caller logs and drops, matching the stdio runtime).

pub fn fail_all(&self)

Fail every pending request (session terminated, expired, or the transport closed). Dropping the senders resolves the waiting receivers with an error.

Trait Implementations

impl Debug for SessionOutbound

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

Formats the value using the given formatter.

impl Default for SessionOutbound

fn default() -> SessionOutbound

Returns the “default value” for a type.