def dipose(self):

        with self.condition:
            if self.timer:
                self.timer.cancel()

            if not self.is_disposed:
                self.is_disposed = True
Ends the thread associated with this scheduler. All remaining work
dataset/ETHPy150Open ReactiveX/RxPY/rx/concurrency/eventloopscheduler.py/EventLoopScheduler.dipose