Struct CreditSink 

pub struct CreditSink<S: ChannelSink> { /* private fields */ }

A ChannelSink wrapper that enforces credit-based flow control.

Each send_payload acquires one permit from the semaphore, blocking if credit is zero. The semaphore is shared with the driver so that incoming GrantCredit messages can add permits via CreditSink::credit.

Implementations

impl<S: ChannelSink> CreditSink<S>

pub fn new(inner: S, initial_credit: u32) -> Self

Wrap inner with initial_credit permits (the const generic N).

pub fn credit(&self) -> &Arc<Semaphore>

Returns the credit semaphore. The driver holds a clone so GrantCredit messages can call add_permits.

Trait Implementations

impl<S: ChannelSink> ChannelSink for CreditSink<S>

Available on non-WebAssembly only.

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

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

fn close_channel_on_drop(&self)

Synchronous drop-time close signal.