Cancel stdin_reader_task after asyncio gor stops

amyangfei · Aug 13, 2022 · d2ddecd · d2ddecd
1 parent 61ce096
commit d2ddecd
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/gor/asyncio_impl.py b/gor/asyncio_impl.py
@@ -45,7 +45,8 @@ async def _run(self):
             t = self.io_loop.create_task(self._worker())
             self.tasks.append(t)
 
-        self.io_loop.create_task(self._stdin_reader())
+        stdin_reader_task = self.io_loop.create_task(self._stdin_reader())
+        self.tasks.append(stdin_reader_task)
 
     def _stop(self):
         for t in self.tasks: