Struct SequencedSender 

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

Sends sequence-numbered messages into a SequencedBroadcast.

Implementations

impl<T> SequencedSender<T>

pub fn seq(&self) -> u64

pub fn is_closed(&self) -> bool

pub async fn closed(&self)

pub fn close(&mut self)

impl<T> SequencedSender<T>

where T: Send + Clone + 'static,

pub async fn send(&mut self, item: T) -> Result<u64, SequencedSenderError<T>>

pub async fn send_at( &mut self, seq: u64, item: T, ) -> Result<u64, SequencedSenderError<T>>

Trait Implementations

impl<T> Drop for SequencedSender<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.