commit 163b3b383bc88cc373f9b97f8f458995f09bf498 Author: Illia Volochii illia.volochii@gmail.com Date: Thu Apr 30 19:29:37 2020 +0300
Stop canceling asynchronous tasks for reader and event loops
They finish automatically when detect that their controller is not alive. --- stem/control.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-)
diff --git a/stem/control.py b/stem/control.py index 98631428..ff0f3bc1 100644 --- a/stem/control.py +++ b/stem/control.py @@ -641,7 +641,6 @@ class BaseController(_BaseControllerSocketMixin): self._socket = control_socket
self._asyncio_loop = asyncio.get_event_loop() - self._asyncio_loop_tasks = []
self._msg_lock = _MsgLock()
@@ -785,9 +784,6 @@ class BaseController(_BaseControllerSocketMixin):
await self._socket.close()
- for task in self._asyncio_loop_tasks: - task.cancel() - # Join on any outstanding state change listeners. Closing is a state change # of its own, so if we have any listeners it's quite likely there's some # work in progress. @@ -951,7 +947,7 @@ class BaseController(_BaseControllerSocketMixin): """
for coroutine in (self._reader_loop(), self._event_loop()): - self._asyncio_loop_tasks.append(self._asyncio_loop.create_task(coroutine)) + self._asyncio_loop.create_task(coroutine)
async def _reader_loop(self) -> None: """
tor-commits@lists.torproject.org