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.