Module channel

Available on crate feature async only.

Channel utilities and extensions.

Modules

trigger

Trigger channels.

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.

Functions

instrumented_unbounded_channel

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