Struct FragmentAssembler 

pub struct FragmentAssembler { /* private fields */ }

Assembles fragments keyed by fragment_id until all parts arrive.

Implementations

impl FragmentAssembler

pub fn new() -> FragmentAssembler

pub fn push( &mut self, shard: FragmentShard, ) -> Result<Option<Vec<u8>>, FragmentError>

Push a new fragment; returns Some(full_payload) when completed.

pub fn inflight(&self) -> usize

pub fn enforce_retention(&mut self, retention: FragmentRetention)

Apply retention: evict oldest if exceeding max inflight.

Trait Implementations

impl Debug for FragmentAssembler

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

Formats the value using the given formatter.

impl Default for FragmentAssembler

fn default() -> FragmentAssembler

Returns the “default value” for a type.