@extensionmethod(Observable)
def skip_with_time(self, duration, scheduler=None):

    source = self
    scheduler = scheduler or timeout_scheduler

    def subscribe(observer):
        open = [False]

        def action(scheduler, state):
            open[0] = True

        t = scheduler.schedule_relative(duration, action)

        def on_next(x):
            if open[0]:
                observer.on_next(x)

        d = source.subscribe(on_next, observer.on_error, observer.on_completed)
        return CompositeDisposable(t, d)
    return AnonymousObservable(subscribe)
Skips elements for the specified duration from the start of the
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/skipwithtime.py/skip_with_time