Module on_backpressure_latest 

Structs

OnBackpressureLatest

Keeps only the most recent upstream item while the downstream observer is still processing the previous one. Once the RequestCallbackType is invoked, the latest buffered value is emitted and the cycle repeats. This mirrors onBackpressureLatest in other ReactiveX stacks. See https://reactivex.io/documentation/operators/backpressure.html.