Struct PartialMessage 

struct PartialMessage {
    deadline: Instant,
    expires_at: Instant,
    total_len: usize,
    topic: Option<String>,
    next_index: u32,
    payload: Vec<u8>,
}

Fields

deadline: Instant

REASSEMBLY_TIMEOUT after the first fragment.

expires_at: Instant

Time at which the message is discarded if still incomplete: the earlier of deadline and REASSEMBLY_IDLE_TIMEOUT after the last fragment.

total_len: usize

topic: Option<String>

next_index: u32

payload: Vec<u8>

Grows with the received data, so a peer that declares a large size without sending it does not hold that memory.

Implementations

impl PartialMessage

fn check( &self, header: &FragmentHeader, topic: &Option<String>, data_len: usize, ) -> Result<(), ReassemblyError>

Returns an error if a fragment cannot be the next one of this message.

fn append(&mut self, data: &[u8])

fn is_complete(&self) -> bool