Struct SyncReceiver 

pub struct SyncReceiver { /* private fields */ }

Available on crate feature sync only.

Receiver for incoming sync messages

Tracks received versions and detects duplicates/stale messages.

Implementations

impl SyncReceiver

pub fn new() -> Self

Create a new receiver

pub fn highest_received(&self) -> u64

Get highest version received from peer

pub fn last_acked_to_peer(&self) -> u64

Get last version we acknowledged to 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 for the given version

pub fn receive_raw( &mut self, data: &[u8], ) -> Result<(ReceiveResult, SyncMessage), MessageError>

Process a raw message from wire format

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 SyncReceiver

fn clone(&self) -> SyncReceiver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncReceiver

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

Formats the value using the given formatter.

impl Default for SyncReceiver

fn default() -> Self

Returns the “default value” for a type.