Struct Reassembler 

pub(crate) struct Reassembler {
    state: Mutex<ReassemblyState>,
    timeout: Duration,
    idle_timeout: Duration,
}

Reassembles fragmented messages received from untrusted peers.

Fields

state: Mutex<ReassemblyState>

timeout: Duration

idle_timeout: Duration

Implementations

impl Reassembler

pub(crate) fn new(timeout: Duration, idle_timeout: Duration) -> Self

Creates a reassembler that discards incomplete messages timeout after their first fragment, or earlier when no fragment arrives for idle_timeout. Expired messages are discarded when the next fragment from any source arrives.

pub(super) fn original_topic(topic: Option<&str>) -> Option<Option<String>>

Returns None if topic does not mark a fragment, otherwise the topic of the message the fragment belongs to.

pub(crate) fn process( &self, message: IncomingMessage, ) -> Option<IncomingMessage>

Passes non-fragment messages through, and returns a reassembled message once its last fragment arrives. Invalid fragments are logged and dropped.

fn accept( &self, message: IncomingMessage, topic: Option<String>, now: Instant, ) -> Result<Option<IncomingMessage>, ReassemblyError>

Appends one fragment received at now and returns the reassembled message once the last fragment arrived. Any inconsistency discards the whole incomplete message.