@extensionmethod(Observable)
def buffer_with_time_or_count(self, timespan, count, scheduler):

    scheduler = scheduler or timeout_scheduler
    return self.window_with_time_or_count(timespan, count, scheduler) \
        .flat_map(lambda x: x.to_iterable())
Projects each element of an observable sequence into a buffer that
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/bufferwithtimeorcount.py/buffer_with_time_or_count