Struct Receiver 

pub struct Receiver { /* private fields */ }

Local retained-body accounting. Capacity is never advertised to a sender. The adapter reserves actual payload backing before retaining a suffix.

Implementations

impl Receiver

pub fn new( channel: Channel, base: Prefix, limits: PipelineLimits, ) -> Result<Self, FlowError>

Start at an exact applied prefix with a bounded local metadata window.

pub const fn report(&self) -> Report

Exact contiguous receipt. This supplies no persistence or vote evidence.

pub fn available(&self) -> PipelineLimits

Local room after every still-retained body, independently of queue slots.

pub fn reinitialize( &mut self, channel: Channel, applied: Prefix, ) -> Result<(), FlowError>

Install a fresh incarnation after all old payload ownership is fenced.

pub fn retract( &mut self, epoch: ReceiveEpoch, through: Prefix, ) -> Result<(), FlowError>

Retract only unadmitted history. Accepted bodies remain charged. Caller fences old packets and supplies a never-reused receive epoch.

pub fn retain( &mut self, channel: Channel, operations: &[Operation], ) -> Result<(), FlowError>

Charge a complete contiguous suffix after physical backing is reserved. Duplicates are filtered by the adapter before this transition.

pub fn release(&mut self, through: Prefix) -> Result<(), FlowError>

Release after application and durable persistence. This changes local room only. It emits no receipt or admission grant.

Trait Implementations

impl Debug for Receiver

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

Formats the value using the given formatter.