Module mpsc 

Available on crate feature common only.

Support for metering senders. Facilitates debugging by exposing metrics for number of messages sent, number of errors, etc.

Structs

MemoryBoundedReceiver

A receiver for memory-bounded messages.

MemoryBoundedSender

A sender that enforces a byte budget before enqueueing messages.

MeteredPollSender

A wrapper type around [PollSender] that updates metrics on send.

MeteredReceiver

A wrapper type around Receiver that updates metrics on receive.

MeteredSender

A wrapper type around Sender that updates metrics on send.

MeteredSenderMetrics

Throughput metrics for MeteredSender

OwnedPermit

A wrapper type around OwnedPermit that updates metrics accounting when sending

Permit

A wrapper type around Permit that updates metrics accounting when sending

UnboundedMeteredReceiver

A wrapper type around UnboundedReceiver that updates metrics on receive.

UnboundedMeteredSender

A wrapper type around UnboundedSender that updates metrics on send.

Functions

memory_bounded_channel

Creates a new memory-bounded channel with the given byte budget.

metered_channel

Wrapper around [mpsc::channel] that returns a new bounded metered channel with the given buffer size.

metered_unbounded_channel

Wrapper around [mpsc::unbounded_channel] that returns a new unbounded metered channel.