Module async_listen::backpressure

Backpressure handling structures

The usual way to apply backpressure to a stream is using one of the ListenExt trait methods:

• backpressure
• apply_backpressure
• backpressure_wrapper

Also take a look at backpressure::new for the low-level interface.

Structs

Backpressure	A stream combinator that applies backpressure and yields a token
BackpressureToken	A stream combinator that applies backpressure
BackpressureWrapper	A stream combinator that applies backpressure and yields ByteStream
HasCapacity	Future that resolves when there is less that limit tokens alive
Receiver	The throttler of a stream
Sender	The handle that controls backpressure
Token	The token which holds onto a single resource item

Functions

new	Create a new pair of backpressure structures