Aligned pausable_buffered with RxJS
Aligned backpressure with RxJS