Struct orouter_wireless::MessagePool

pub struct MessagePool { /* private fields */ }

Holds parts of multipart messages before all parts have arrived

Messages in vector under each prefix key are inserted at the correct index - are kept sorted example of the map

{
    '3B prefix': \[\[part_1\], \[part_2\], \[part3\]\], // these are ordered
    ...
    ...
}

Implementations

impl MessagePool

pub fn try_insert( &mut self, msg: P2pMessagePart ) -> Result<Option<P2pMessage>, Error>

Try insert another part of sliced message. Will return None if this is not last (or the only) message, else it will return just the data of this message (stripped of all the now unnecessart protocol meta data)

pub fn size(&self) -> u8

Returns how many message parts (regardless of which message is the part of) are currently being held by the internal state.

pub fn reset(&mut self)

Resets the internal state of the pool. This equals constructing of a new pool - all the message parts of unfinished messages inserted before calling of this method will be lost.

Trait Implementations

impl Default for MessagePool

fn default() -> Self

Returns the “default value” for a type.