Struct ChunkedConsumer 

pub struct ChunkedConsumer { /* private fields */ }

Reassembles segments produced by ChunkedProducer into the original payload.

Segments may arrive out of order; receive_segment inserts each one by index. reassemble returns Some(Bytes) once all segments are present.

Implementations

impl ChunkedConsumer

pub fn new(prefix: Name, segment_count: usize) -> Self

Create a consumer expecting exactly segment_count segments.

pub fn prefix(&self) -> &Name

pub fn segment_count(&self) -> usize

pub fn receive_segment(&mut self, index: usize, payload: Bytes)

Store the payload for index. Out-of-range indices are silently dropped.

pub fn is_complete(&self) -> bool

Returns true when every segment has been received.

pub fn reassemble(&self) -> Option<Bytes>

Concatenate all segments in order. Returns None if incomplete.