code: def run(self):
          
          executor = concurrent.futures.ThreadPoolExecutor(max_workers=1)
          loop = asyncio.get_event_loop()
          loop.run_until_complete(self._run_loop(executor))
          self._log.info('Shutting down...')
          executor.shutdown()
docs: Starts the receiver.