@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)
:param typ: Type of key (rsa, ec, oct, ..)
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/skipwithtime.py/skip_with_time--crossover with--dataset/ETHPy150Open rohe/pyoidc/src/oic/utils/keyio.py/KeyBundle.remove_key