code: async def async_run(self) -> None:
          
          self.main_task = self.loop.create_task(self.main())
          await self.main_task
docs: Asynchronously run the worker, does not close connections. Useful when testing.