Function mz_ore::channel::instrumented_unbounded_channel

source · 
pub fn instrumented_unbounded_channel<T, M>(
    sender_metric: M,
    receiver_metric: M
) -> (InstrumentedUnboundedSender<T, M>, InstrumentedUnboundedReceiver<T, M>)
where
    M: InstrumentedChannelMetric,
Available on crate feature async only.
Expand description

A wrapper around tokio’s mpsc unbounded channels that connects metrics that are incremented when sends or receives happen.