Module metered_channel
Source - Permit
- A newtype for an
mpsc::Permit which allows us to inject gauge accounting
in the case the permit is dropped w/o sending - Receiver
- An [
mpsc::Receiver] with an [IntGauge]
counting the number of currently queued items. - ReceiverStream
- A wrapper around
crate::metered_channel::Receiver that implements [Stream]. - Sender
- An [
mpsc::Sender] with an [IntGauge]
counting the number of currently queued items. - WeakSender
- An [
mpsc::WeakSender] with an [IntGauge]
counting the number of currently queued items.
- WithPermit
- channel
- Similar to
mpsc::channel, channel creates a pair of Sender and Receiver
Deprecated: use monitored_mpsc::channel instead. - channel_with_total
- Deprecated: use
monitored_mpsc::channel instead.