Struct SegmentReassembler 

pub struct SegmentReassembler { /* private fields */ }

Reassembles segmented PVA messages.

Sans-io: the caller reads a header and payload off the wire and pushes them in. One instance per connection, because a message’s segments may be separated by control frames that the caller handles in between.

Implementations

impl SegmentReassembler

pub fn new() -> SegmentReassembler

A reassembler with the DEFAULT_MAX_MESSAGE_BYTES cap.

pub fn with_max_bytes(max_bytes: usize) -> SegmentReassembler

A reassembler with a custom cap on the reassembled message size.

pub fn pending_bytes(&self) -> usize

Bytes of payload currently held for an in-progress message.

pub fn reset(&mut self)

Discard any in-progress message. Call this when the connection resets.

pub fn push( &mut self, header: [u8; 8], payload: Vec<u8>, ) -> Result<SegmentOutcome, DecodeError>

Feed one frame. See SegmentOutcome.

On any Err the in-progress message is discarded and the reassembler is ready for the next one; the caller decides whether to keep the connection.

Trait Implementations

impl Default for SegmentReassembler

fn default() -> SegmentReassembler

Returns the “default value” for a type.