@defer.inlineCallbacks
    def startService(self):
        self.running = True
        self.running_service = True

        while self.running_service:
            try:
                yield threads.deferToThread(self._run)
            except Exception as e:
                log.error()
Start the reqest in the reactors thread pool.
dataset/ETHPy150Open foundit/Piped/doc/tutorials/twitter/4_processor/twitter_tutorial/provider.py/TwitterStream.startService