Struct DuplexClient 

pub struct DuplexClient<Out: RemoteMessage, In: RemoteMessage> { /* private fields */ }

A handle to a duplex client session: wraps the send/recv halves and the spawned task driving the connection. Owns a cancellation token so callers can deterministically stop the recv/send loop via DuplexClient::join.

Dropping a DuplexClient does not cancel — that would tear down sessions whose tx/rx halves the application has handed off elsewhere (e.g., into a mailbox). Call join for orderly shutdown.

Implementations

impl<Out: RemoteMessage, In: RemoteMessage> DuplexClient<Out, In>

pub fn tx(&self) -> DuplexTx<Out>

Get a new clone of the DuplexTx for sending messages to the peer.

pub fn take_rx(&mut self) -> Option<DuplexRx<In>>

Take the DuplexRx out of the client. Returns None on subsequent calls — the receiver is single-consumer.

pub fn addr(&self) -> &ChannelAddr

The peer address this client dialed.

pub async fn join(self)

Gracefully shut down the duplex client session. Cancels the recv/send loop’s cancellation token (which the spawned task observes in its select!s) and awaits the spawned task. On return, the task has finished its terminal cleanup (final ack flush on ACCEPTOR_TO_INITIATOR) and dropped its inbound_tx / outbound receiver halves — so any in-progress DuplexRx::recv on the receiver half resolves with ChannelError::Closed.

Trait Implementations

impl<Out: RemoteMessage, In: RemoteMessage> Debug for DuplexClient<Out, In>

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

Formats the value using the given formatter.