Struct MessageBuffer 

pub struct MessageBuffer { /* private fields */ }

Message buffer for ordering and deduplication.

Implementations

impl MessageBuffer

pub fn new() -> Self

Create a new message buffer.

pub fn process(&mut self, id: &str, seq: u64, payload: Value) -> Option<Value>

Process a message and return it if it’s the next in sequence.

pub fn last_seq(&self, id: &str) -> u64

Get the last processed sequence for a subscription.

pub fn pending_count(&self, id: &str) -> usize

Get the number of pending messages for a subscription.

pub fn clear(&mut self, id: &str)

Clear buffer for a subscription.

pub fn clear_all(&mut self)

Clear all buffers.

Trait Implementations

impl Debug for MessageBuffer

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

Formats the value using the given formatter.

impl Default for MessageBuffer

fn default() -> MessageBuffer

Returns the “default value” for a type.