Struct DriverChannelSink 

pub struct DriverChannelSink { /* private fields */ }

Concrete ChannelSink backed by a ConnectionSender.

Created by the driver when setting up outbound channels (Tx handles). Sends ChannelItem and ChannelClose messages through the connection. Wrapped with CreditSink to enforce credit-based flow control.

Trait Implementations

impl ChannelSink for DriverChannelSink

fn send_payload<'payload>( &self, payload: Payload<'payload>, ) -> Pin<Box<dyn MaybeSendFuture<Output = Result<(), TxError>> + 'payload>>

fn close_channel( &self, _metadata: Metadata<'_>, ) -> Pin<Box<dyn MaybeSendFuture<Output = Result<(), TxError>> + 'static>>

fn close_channel_on_drop(&self)

Synchronous drop-time close signal.