Module on_backpressure_buffer

rx_rust::operators::backpressure

Module on_backpressure_buffer 

Source

Structsยง

OnBackpressureBuffer
Buffers every upstream item into a Vec<T> and only delivers the collected batch once the downstream observer calls the accompanying RequestCallbackType. This mirrors the behavior of onBackpressureBuffer from other ReactiveX implementations. See https://reactivex.io/documentation/operators/backpressure.html.