Struct PfaReassemblyBuffer 

pub struct PfaReassemblyBuffer {
    pub msg_id: PfaMessageId,
    pub received: Vec<Option<PfaFragment>>,
    pub total_fragments: u32,
    pub created_at: u64,
    pub last_updated: u64,
    /* private fields */
}

Internal buffer accumulating received fragments for one message.

Fields

msg_id: PfaMessageId

Message identifier.

received: Vec<Option<PfaFragment>>

Slots for each expected fragment; None means not yet received.

total_fragments: u32

How many fragments are expected in total.

created_at: u64

Unix-epoch seconds when the buffer was first created.

last_updated: u64

Unix-epoch seconds of the most recently received fragment.

Implementations

impl PfaReassemblyBuffer

pub fn received_count(&self) -> u32

Returns how many non-duplicate fragments have been stored.

pub fn is_complete(&self) -> bool

Returns true when all fragments have been received.

Trait Implementations

impl Debug for PfaReassemblyBuffer

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

Formats the value using the given formatter.