Struct SequencedSender

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

Implementations

impl<T> SequencedSender<T>

pub fn new(next_seq: u64, send: Sender<(u64, T)>) -> Self

pub fn is_closed(&self) -> bool

pub async fn closed(&self)

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

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

pub fn try_send(&mut self, item: T) -> Result<(), TrySendError<T>>

pub async fn reserve( &mut self, ) -> Result<SequencedSenderPermit<'_, T>, SendError<()>>

pub fn seq(&self) -> u64