Struct StreamLinkTx 

pub struct StreamLinkTx { /* private fields */ }

Sending half of a StreamLink.

Internally uses a bounded mpsc channel (capacity 1) to serialize writes and provide backpressure. A background task drains the channel and writes length-prefixed frames to the underlying stream.

Trait Implementations

impl LinkTx for StreamLinkTx

type Permit = StreamLinkTxPermit

async fn reserve(&self) -> Result<Self::Permit>

Reserve capacity to send exactly one payload.

async fn close(self) -> Result<()>

Graceful close of the outbound direction.