pub struct EventStreamLagged {
pub skipped: u64,
}Expand description
A live subscription fell behind the publisher and skipped events.
Publishers yield this as a stream item — never a silent skip and never a silent stream end — and then continue with subsequent live events, so the consumer always learns exactly how many events it missed.
Fields§
§skipped: u64Number of events the subscriber missed.
Trait Implementations§
Source§impl Clone for EventStreamLagged
impl Clone for EventStreamLagged
Source§fn clone(&self) -> EventStreamLagged
fn clone(&self) -> EventStreamLagged
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Copy for EventStreamLagged
Source§impl Debug for EventStreamLagged
impl Debug for EventStreamLagged
Source§impl Display for EventStreamLagged
impl Display for EventStreamLagged
impl Eq for EventStreamLagged
Source§impl Error for EventStreamLagged
impl Error for EventStreamLagged
1.30.0 · Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
👎Deprecated since 1.42.0:
use the Display impl or to_string()
Source§impl PartialEq for EventStreamLagged
impl PartialEq for EventStreamLagged
impl StructuralPartialEq for EventStreamLagged
Auto Trait Implementations§
impl Freeze for EventStreamLagged
impl RefUnwindSafe for EventStreamLagged
impl Send for EventStreamLagged
impl Sync for EventStreamLagged
impl Unpin for EventStreamLagged
impl UnsafeUnpin for EventStreamLagged
impl UnwindSafe for EventStreamLagged
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.