Crate re_quota_channel 

A mpsc channel that applies backpressure based on byte size.

Re-exports

pub use sync::Receiver;

pub use sync::Select;

pub use sync::SelectedOperation;

pub use sync::Sender;

pub use sync::channel;

Modules

async_broadcast_channel

Async (tokio-based) broadcast channel with byte-based backpressure.

async_mpsc_channel

Thin wrapper around tokio::sync::mpsc that logs a warning if send blocks too long.

sync

Synchronous mpsc channel with byte-based backpressure.

Macros

select

Wait on two receivers and execute whichever branch becomes ready first.

Structs

RecvError

An error returned from the recv method.

SelectTimeoutError

An error returned from the select_timeout method.

SendError

An error returned from the send method.

SizedMessage

A message together with its size in bytes.

TrySelectError

An error returned from the try_select method.

Enums

RecvTimeoutError

An error returned from the recv_timeout method.

TryRecvError

An error returned from the try_recv method.