async def run(self):
logging.info('<STR_LIT>')<EOL>coroutines = set()<EOL>while True:<EOL><INDENT>coro = self._poll_channel()<EOL>coroutines.add(coro)<EOL>_, coroutines = await asyncio.wait(coroutines, timeout=<NUM_LIT:0.1>)<EOL><DEDENT>
Entrypoint to route messages between plugins.