@extensionmethod(Observable)
def buffer_with_time(self, timespan, timeshift=None, scheduler=None):

    if not timeshift:
        timeshift = timespan

    scheduler = scheduler or timeout_scheduler

    return self.window_with_time(timespan, timeshift, scheduler) \
        .select_many(lambda x: x.to_iterable())
Projects each element of an observable sequence into zero or more
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/bufferwithtime.py/buffer_with_time