def ensure_thread(self):

        if not self.thread:
            self.thread = self.thread_factory(self.run)
            self.thread.start()
Ensures there is an event loop thread running. Should be called
dataset/ETHPy150Open ReactiveX/RxPY/rx/concurrency/eventloopscheduler.py/EventLoopScheduler.ensure_thread