Struct sc_utils::status_sinks::StatusSinks

pub struct StatusSinks<T> { /* private fields */ }

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>

pub fn new() -> StatusSinks<T>

Builds a new empty collection.

pub fn push(&self, interval: Duration, sender: TracingUnboundedSender<T>)

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>

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.

Trait Implementations

impl<T> Default for StatusSinks<T>

fn default() -> Self

Returns the “default value” for a type.