[FIX] don't wait for canceled task

src/seahorse/__about__.py

@@ -1,4 +1,4 @@
 # SPDX-FileCopyrightText: 2023-present U.N. Owen <[email protected]>
 #
 # SPDX-License-Identifier: MIT
-__version__ = "1.1.6b0"
+__version__ = "1.1.6b1"

src/seahorse/game/io_stream.py

@@ -3,14 +3,15 @@
 import asyncio
 import functools
 import json
-import time
 import re
-import socketio
+import time
+from collections import deque
+from collections.abc import Coroutine
+from typing import TYPE_CHECKING, Any, Callable
 
-from typing import TYPE_CHECKING, Any, Callable, Coroutine
+import socketio
 from aiohttp import web
 from loguru import logger
-from collections import deque
 
 from seahorse.game.action import Action
 from seahorse.game.heavy_action import HeavyAction
@@ -33,7 +34,8 @@ def activate(self,
 
         Args:
             identifier (str | None, optional): Must be a unique identifier. Defaults to None.
-            wrapped_id (int | None, optional): If the eventSlave is bound to an instance a python native id might be associated. 
+            wrapped_id (int | None, optional): If the eventSlave is bound to an instance,
+                                               a python native id might be associated.
                                                Defaults to None.
         """
         self.sio = socketio.AsyncClient()
@@ -123,7 +125,7 @@ def get_instance(game_state:type=Serializable,port: int = 8080,hostname: str="lo
         """Gets the instance object
 
         Args:
-            n_clients (int, optional): the number of clients the instance is supposed to be listening, 
+            n_clients (int, optional): the number of clients the instance is supposed to be listening,
                                        *ignored* if already initialized. Defaults to 1.
             game_state : class of a game state
             port (int, optional): the port to use. Defaults to 8080.
@@ -137,7 +139,8 @@ def get_instance(game_state:type=Serializable,port: int = 8080,hostname: str="lo
 
     def __init__(self,game_state,port,hostname):
         if EventMaster.__instance is not None:
-            msg = "Trying to initialize multiple instances of EventMaster, this is forbidden to avoid side-effects.\n Call EventMaster.get_instance() instead."
+            msg = "Trying to initialize multiple instances of EventMaster, \
+                this is forbidden to avoid side-effects.\n Call EventMaster.get_instance() instead."
             raise NotImplementedError(msg)
         else:
             # Initializing attributes
@@ -153,7 +156,7 @@ def __init__(self,game_state,port,hostname):
             self.hostname = hostname
 
             # Standard python-socketio server
-            self.sio = socketio.AsyncServer(async_mode="aiohttp", async_handlers=True, 
+            self.sio = socketio.AsyncServer(async_mode="aiohttp", async_handlers=True,
                                             cors_allowed_origins="*", ping_timeout=1e6)
             self.app = web.Application()
 
@@ -181,7 +184,8 @@ def connect(sid, *_):
                 """
                 self.__open_sessions.add(sid)
                 self.__n_clients_connected += 1
-                logger.info(f"Waiting for listeners {self.__n_clients_connected} out of {self.expected_clients} are connected.")
+                logger.info(f"Waiting for listeners {self.__n_clients_connected} \
+                            out of {self.expected_clients} are connected.")
 
             @self.sio.event
             def disconnect(sid):
@@ -342,11 +346,10 @@ async def stop(task):
 
             # Explicitly cancel any remaining tasks related to disconnected clients
             # logger.info("Canceling pending tasks related to disconnected clients.")
-            tasks = [task for task in asyncio.all_tasks() if task is not asyncio.current_task()]
-            for task in tasks:
-                task.cancel()
+            all_pending_tasks = [task for task in asyncio.all_tasks() if task is not asyncio.current_task()]
+            for pending_task in all_pending_tasks:
                 try:
-                    await task
+                    pending_task.cancel()
                 except asyncio.CancelledError:
                     pass