Struct OrderedReceiver 

pub struct OrderedReceiver { /* private fields */ }

Available on crate feature sync only.

Receiver with history for out-of-order message handling

Maintains a sliding window of received versions for detecting duplicates even when messages arrive out of order.

Implementations

impl OrderedReceiver

pub fn new() -> Self

Create a new ordered receiver

pub fn highest_received(&self) -> u64

Get highest version received from peer

pub fn needs_ack(&self) -> bool

Check if we need to send an ack

pub fn mark_acked(&mut self, version: u64)

Mark that we’ve sent an ack

pub fn has_received(&self, version: u64) -> bool

Check if a version has been received

pub fn receive(&mut self, msg: &SyncMessage) -> ReceiveResult

Process an already-decoded message

pub fn reset(&mut self)

Reset receiver state

Trait Implementations

impl Clone for OrderedReceiver

fn clone(&self) -> OrderedReceiver

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OrderedReceiver

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

Formats the value using the given formatter.

impl Default for OrderedReceiver

fn default() -> Self

Returns the “default value” for a type.