@extensionmethod(Observable)
def pausable_buffered(self, subject):

    return PausableBufferedObservable(self, subject)
Pauses the underlying observable sequence based upon the observable
dataset/ETHPy150Open ReactiveX/RxPY/rx/backpressure/pausablebuffered.py/pausable_buffered