Struct SyncSender 

pub struct SyncSender { /* private fields */ }

Available on crate feature sync only.

Sender state for managing outbound sync messages

Implementations

impl SyncSender

pub fn new() -> Self

Create a new sender with default settings

pub fn with_intervals( min_send_interval: Duration, collection_interval: Duration, delayed_ack_timeout: Duration, ) -> Self

Create a sender with custom intervals

pub fn queue_message(&mut self, msg: SyncMessage)

Queue a message for sending

The message will be held until the pacing interval allows sending.

pub fn should_send(&self) -> bool

Check if we should send now

pub fn should_send_at(&self, now: Instant) -> bool

Check if we should send at a given time

pub fn take_if_ready(&mut self) -> Option<SyncMessage>

Take the pending message if we should send now

pub fn take_if_ready_at(&mut self, now: Instant) -> Option<SyncMessage>

Take the pending message if ready at a given time

pub fn take_message(&mut self) -> Option<SyncMessage>

Force-take the pending message (bypass timing checks)

pub fn time_until_send(&self) -> Option<Duration>

Get time until next allowed send

pub fn time_until_send_at(&self, now: Instant) -> Option<Duration>

Get time until next allowed send at a given time

pub fn has_pending(&self) -> bool

Check if there’s a pending message

pub fn pending_message(&self) -> Option<&SyncMessage>

Get reference to pending message

pub fn cancel_pending(&mut self)

Cancel pending message

pub fn mark_ack_needed(&mut self)

Mark that an ack is needed (triggers delayed ack timer)

pub fn reset(&mut self)

Reset sender state

Trait Implementations

impl Debug for SyncSender

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

Formats the value using the given formatter.

impl Default for SyncSender

fn default() -> Self

Returns the “default value” for a type.