Struct RequestReassembler 

pub struct RequestReassembler { /* private fields */ }

Collects request fragments on the drone until a request is whole.

Bounded in count, bytes and time: the uplink is a broadcast any fleet member can transmit on, and nothing in a fragment is authenticated until the whole object (and the ticket inside it) has arrived.

Implementations

impl RequestReassembler

pub fn new() -> Self

pub fn push( &mut self, fragment: &RequestFragment<'_>, now: Instant, ) -> ReassemblyOutcome

Feed one fragment received at now.

pub fn partial_count(&self) -> usize

Requests currently partially held.

Trait Implementations

impl Default for RequestReassembler

fn default() -> Self

Returns the “default value” for a type.