referrerpolicy=no-referrer-when-downgrade

Function sc_utils::mpsc::tracing_unbounded

source ·
pub fn tracing_unbounded<T>(
    name: &'static str,
    queue_size_warning: usize,
) -> (TracingUnboundedSender<T>, TracingUnboundedReceiver<T>)
Expand description

Wrapper around [async_channel::unbounded] that tracks the in- and outflow via UNBOUNDED_CHANNELS_COUNTER and warns if the message queue grows above the warning threshold.