Enum task_executor::broadcast::error::RecvError [−]
pub enum RecvError {
Closed,
Lagged(u64),
}
Variants
There are no more active senders implying no further messages will ever be sent.
Lagged(u64)
The receiver lagged too far behind. 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 StructuralPartialEq for RecvError
Auto Trait Implementations
impl RefUnwindSafe for RecvError
impl UnwindSafe for RecvError
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