Module on_backpressure 

Structs

OnBackpressure

Low-level primitive that converts a fast upstream into demand-driven chunks by accumulating values with a custom receiving_strategy and emitting them alongside a RequestCallbackType. Downstream observers must invoke the callback to resume the upstream flow. See https://reactivex.io/documentation/operators/backpressure.html.

Type Aliases

RequestCallbackType

Callback handed to the downstream observer so it can request the next chunk once it finishes processing the current batch.