Enum RecvError
pub enum RecvError {
Closed,
Lagged(u64),
}
Available on crate feature
sync only.Variants
Closed
There are no more active senders implying no further messages will ever be sent.
Lagged(u64)
The receiver lagged too far behind: one or more messages were overwritten in the ring buffer before this receiver could read them.
The receiver remains subscribed. Its internal cursor has been advanced to the oldest message still retained by the channel; the next successful recv call returns that message (unless further sends overwrite it first).
The u64 is the number of messages that were skipped (dropped before the receiver’s previous cursor position).
Trait Implementations
impl Eq for RecvError
impl Error for RecvError
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
fn description(&self) -> &str
👎Deprecated since 1.42.0:
use the Display impl or to_string()
impl StructuralPartialEq for RecvError
Auto Trait Implementations
impl Freeze for RecvError
impl RefUnwindSafe for RecvError
impl Send for RecvError
impl Sync for RecvError
impl Unpin for RecvError
impl UnsafeUnpin for RecvError
impl UnwindSafe for RecvError
Blanket Implementations
impl<T> BorrowMut<T> for Twhere T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<T> CloneToUninit for Twhere T: Clone,
unsafe fn clone_to_uninit(&self, dest: *mut u8)
🔬This is a nightly-only experimental API. (
clone_to_uninit)
impl<T> Instrument for T
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
impl<T> ToString for T
impl<T> WithSubscriber for T
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
MIT License
Copyright © Tokio Contributors
https://docs.rs/tokio/1.53.1/tokio/sync/broadcast/error/enum.RecvError.html