def schedule(self, action, state=None):

        scheduler = self
        disposable = SingleAssignmentDisposable()

        def interval():
            disposable.disposable = action(scheduler, state)
        timer = Timer(0, interval)
        timer.setDaemon(True)
        timer.start()

        def dispose():
            timer.cancel()
        return CompositeDisposable(disposable, Disposable(dispose))
Schedules an action to be executed.
dataset/ETHPy150Open ReactiveX/RxPY/rx/concurrency/timeoutscheduler.py/TimeoutScheduler.schedule