Enum task_executor::broadcast::error::TryRecvError [−]
pub enum TryRecvError {
Empty,
Closed,
Lagged(u64),
}
Variants
The channel is currently empty. There are still active
Sender
handles, so data may yet become available.
There are no more active senders implying no further messages will ever be sent.
Lagged(u64)
The receiver lagged too far behind and has been forcibly disconnected. Attempting to receive again will return the oldest message still retained by the channel.
Includes the number of skipped messages.
Tuple Fields of Lagged
0: u64
Trait Implementations
impl Debug for TryRecvError
impl Debug for TryRecvError
impl Display for TryRecvError
impl Display for TryRecvError
impl Error for TryRecvError
impl Error for TryRecvError
impl PartialEq<TryRecvError> for TryRecvError
impl PartialEq<TryRecvError> for TryRecvError
pub fn eq(&self, other: &TryRecvError) -> bool
pub fn eq(&self, other: &TryRecvError) -> bool
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
pub fn ne(&self, other: &TryRecvError) -> bool
pub fn ne(&self, other: &TryRecvError) -> bool
This method tests for !=
.
impl StructuralPartialEq for TryRecvError
Auto Trait Implementations
impl RefUnwindSafe for TryRecvError
impl Send for TryRecvError
impl Sync for TryRecvError
impl Unpin for TryRecvError
impl UnwindSafe for TryRecvError
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn into_collection<A>(self) -> SmallVec<A> where
A: Array<Item = T>,
pub fn into_collection<A>(self) -> SmallVec<A> where
A: Array<Item = T>,
Converts self
into a collection.
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more