Struct DriverCaller 

pub struct DriverCaller { /* private fields */ }

Implements Caller: 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 Caller for DriverCaller

async fn call<'a>(&'a self, call: RequestCall<'a>) -> CallResult

Start one outgoing request attempt for an API-level call and wait for its response.

fn closed(&self) -> BoxFut<'_, ()>

Resolve when the underlying connection closes.

fn is_connected(&self) -> bool

Return whether the underlying connection is still considered connected.

fn channel_binder(&self) -> Option<&dyn ChannelBinder>

Return a channel binder for binding Tx/Rx handles in args before sending.

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.

impl From<DriverCaller> for NoopCaller

fn from(caller: DriverCaller) -> Self

Converts to this type from the input type.