Struct sp_utils::status_sinks::StatusSinks [−][src]
Holds a list of UnboundedSenders, each associated with a certain time period. Every time the
period elapses, we push an element on the sender.
Senders are removed only when they are closed.
Implementations
impl<T> StatusSinks<T>[src]
pub fn new() -> StatusSinks<T>[src]
Builds a new empty collection.
pub fn push(&self, interval: Duration, sender: TracingUnboundedSender<T>)[src]
Adds a sender to the collection.
The interval is the time period between two pushes on the sender.
pub async fn next(&self) -> ReadySinkEvent<'_, T>[src]
Waits until one of the sinks is ready, then returns an object that can be used to send an element on said sink.
If the object isn’t used to send an element, the slot is skipped.
Auto Trait Implementations
impl<T> !RefUnwindSafe for StatusSinks<T>
impl<T> Send for StatusSinks<T> where
T: Send,
T: Send,
impl<T> Sync for StatusSinks<T> where
T: Send,
T: Send,
impl<T> Unpin for StatusSinks<T>
impl<T> !UnwindSafe for StatusSinks<T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,