Struct DriverCaller 

pub struct DriverCaller { /* private fields */ }

Allocates a request ID, registers a response slot, sends one request attempt through the connection, and awaits the corresponding response.

Implementations

impl DriverCaller

pub fn create_tx_channel( &self, ) -> (ChannelId, Arc<CreditSink<DriverChannelSink>>)

Allocate a channel ID and create a credit-controlled sink for outbound items.

The returned sink enforces credit; the semaphore is registered so GrantCredit messages can add permits.

pub fn register_rx_channel(&self, channel_id: ChannelId) -> BoundChannelReceiver

Register an inbound channel (Rx on our side) and return the receiver.

The channel ID comes from the peer (e.g. from RequestCall.channels). The returned receiver should be bound to an Rx handle via Rx::bind().

Trait Implementations

impl ChannelBinder for DriverCaller

fn create_tx(&self) -> (ChannelId, Arc<dyn ChannelSink>)

Allocate a channel ID and create a sink for sending items.

fn create_rx(&self) -> (ChannelId, BoundChannelReceiver)

Allocate a channel ID, register it for routing, and return a receiver.

fn bind_tx(&self, channel_id: ChannelId) -> Arc<dyn ChannelSink>

Create a sink for a known channel ID (callee side).

fn register_rx(&self, channel_id: ChannelId) -> BoundChannelReceiver

Register an inbound channel by ID and return the receiver (callee side).

fn channel_liveness(&self) -> Option<ChannelLivenessHandle>

Optional opaque handle that keeps the underlying session/connection alive for the lifetime of any bound channel handle.

impl Clone for DriverCaller

fn clone(&self) -> DriverCaller

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.