Struct SequencedReceiver 

pub struct SequencedReceiver<T> { /* private fields */ }

Receives sequence-numbered messages from replay history and live broadcast.

A receiver may observe the same sequence in both its catch-up replay and the live broadcast channel. This type treats those repeated sequences as duplicates and skips them before returning the next expected message.

Implementations

impl<T> SequencedReceiver<T>

where T: Send + Clone + 'static,

pub async fn recv(&mut self) -> Result<(u64, T), SequencedRecvError>

pub fn try_recv(&mut self) -> Result<(u64, T), SequencedTryRecvError>

pub fn next_seq(&self) -> u64

pub fn is_closed(&self) -> bool

Trait Implementations

impl<T> Drop for SequencedReceiver<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.