Module mz_ore::channel

Available on crate feature async only.

Channel utilities and extensions.

Structs

• GuardedReceiver
  A wrapper around oneshot::Receiver that will call the provided closure if there is a value in the receiver when it’s dropped.
• InstrumentedUnboundedReceiver
  A wrapper around tokio’s UnboundedReceiver that increments a metric when a recv finishes.
• InstrumentedUnboundedSender
  A wrapper around tokio’s UnboundedSender that increments a metric when a send occurs.

Traits

• InstrumentedChannelMetric
  A trait describing a metric that can be used with an instrumented_unbounded_channel.
• OneshotReceiverExt
  Extensions for oneshot channel types.
• ReceiverExt
  Extensions for the receiving end of asynchronous channels.

Functions

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