Module 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 adapter that applies backpressure and yields a token

BackpressureToken

A stream adapter that applies backpressure

BackpressureWrapper

A stream adapter 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