Struct PossibleGapBuffer 

pub struct PossibleGapBuffer { /* private fields */ }

Buffers updates received during a possible-gap window so we don’t fire getDifference on every slightly out-of-order update.

Implementations

impl PossibleGapBuffer

pub fn new() -> Self

pub fn push_global(&mut self, upd: Update)

Buffer a global update during a possible-gap window.

pub fn push_channel(&mut self, channel_id: i64, upd: Update)

Buffer a channel update during a possible-gap window.

pub fn global_deadline_elapsed(&self) -> bool

True if the global possible-gap deadline has elapsed.

pub fn channel_deadline_elapsed(&self, channel_id: i64) -> bool

True if a channel’s possible-gap deadline has elapsed.

pub fn has_global(&self) -> bool

True if the global buffer has any pending updates.

pub fn has_channel(&self, channel_id: i64) -> bool

True if a channel buffer has pending updates.

pub fn drain_global(&mut self) -> Vec<Update>

Drain global buffered updates.

pub fn drain_channel(&mut self, channel_id: i64) -> Vec<Update>

Drain channel buffered updates.

Trait Implementations

impl Default for PossibleGapBuffer

fn default() -> PossibleGapBuffer

Returns the “default value” for a type.