Struct Sender 

pub struct Sender(/* private fields */);

The capability to publish one endpoint’s outbound flow.

Implementations

impl Sender

pub fn id(&self) -> ExchangeId

pub fn flow(&self) -> Flow

pub fn chunk_geometry(&self) -> ChunkGeometry

Physical geometry of this sender’s actual directional payload arena.

pub fn plan_chunks(&self, data_bytes: usize) -> Result<ChunkPlan>

Plan a known payload for this direction’s actual arena geometry.

pub fn plan_chunks_with( &self, data_bytes: usize, slots_per_chunk: usize, ) -> Result<ChunkPlan>

Plan this direction with a runtime-selected slot count.

pub fn start(&mut self, metadata: Option<&[u8]>) -> Result<()>

pub fn reserve_start(&mut self, payload_len: usize) -> Result<PendingStart<'_>>

Reserve start metadata directly in the shared payload arena. No start event is visible until the returned guard is committed.

pub fn data(&mut self, payload: &[u8]) -> Result<ChunkDescriptor>

pub fn reserve_data(&mut self, payload_len: usize) -> Result<PendingData<'_>>

Reserve one variable-sized data chunk directly in the payload arena. One commit emits one data descriptor.

pub fn finish(&mut self) -> Result<()>

pub fn reset(&mut self, code: ResetCode) -> Result<()>

pub fn wait_writable(&self) -> Result<()>

pub fn poll_writable(&self, cx: &mut Context<'_>) -> Poll<Result<()>>

pub fn wait_ready(&self, payload_len: usize) -> Result<()>

Wait for both one control frame and the payload credit needed by the next publication. Use zero for FIN, RESET, or a start without metadata.

pub fn poll_ready( &self, payload_len: usize, cx: &mut Context<'_>, ) -> Poll<Result<()>>

Task readiness for the same combined control and payload capacity. Both sources register before Pending is returned.