()
| 177 | |
| 178 | |
| 179 | async def _main(): |
| 180 | exec_queue = asyncio.Queue() |
| 181 | reader = asyncio.create_task(_read_stdin(exec_queue)) |
| 182 | try: |
| 183 | while True: |
| 184 | message = await exec_queue.get() |
| 185 | if message is None: |
| 186 | return |
| 187 | await _handle_exec(message) |
| 188 | finally: |
| 189 | reader.cancel() |
| 190 | |
| 191 | |
| 192 | if __name__ == "__main__": |
no test coverage detected