remove wait when disconnecting http transport

Author: josephlim94

janus_client/transport_http.py

@@ -149,13 +149,15 @@ async def dispatch_session_destroyed(self, session_id: int) -> None:
 
         logger.info(f"Destroy session_receive_response task ({session_id})")
         receiver_task = self.__receive_response_task_map[session_id]
-        # Don't use task.cancel() to avoid
-        # Exception ignored in: <function _ProactorBasePipeTransport.__del__ at 0x0000027A269465F0>
-        receiver_task.destroyed_event.set()
-
-        # Destroying sessions could cost some time because it needs to
-        # wait for the long-poll request to complete
-        await asyncio.wait([receiver_task.task])
+        receiver_task.task.cancel()
+        # I think the following problem was fixed when aiohttp version was updated
+        # # Don't use task.cancel() to avoid
+        # # Exception ignored in: <function _ProactorBasePipeTransport.__del__ at 0x0000027A269465F0>
+        # receiver_task.destroyed_event.set()
+
+        # # Destroying sessions could cost some time because it needs to
+        # # wait for the long-poll request to complete
+        # await asyncio.wait([receiver_task.task])
 
 
 def protocol_matcher(base_url: str):

pyproject.toml

@@ -46,6 +46,9 @@ dependencies = [
     "python-dotenv>=1.0.0",
 ]
 
+[[tool.hatch.envs.default.matrix]]
+python = ["3.8", "3.9", "3.10", "3.11", "3.12", "3.13"]
+
 [tool.hatch.envs.default.scripts]
 docs-build = "python -W ignore::DeprecationWarning:mkdocs_autorefs -m mkdocs build --clean --strict"
 docs-serve = "mkdocs serve"

test_echotest.py

@@ -1,6 +1,11 @@
 import asyncio
 import logging
 import os
+from urllib.parse import urljoin
+
+from dotenv import load_dotenv
+
+load_dotenv()
 
 # from janus_client.transport import JanusTransportHTTP
 from janus_client import JanusSession, JanusEchoTestPlugin
@@ -14,8 +19,14 @@ async def main():
     # transport = JanusTransportHTTP(
     #     uri="https://janusmy.josephgetmyip.com/janusbase/janus"
     # )
-    session = JanusSession(base_url="wss://janusmy.josephgetmyip.com/janusbasews/janus")
-    # session = JanusSession(base_url="https://janusmy.josephgetmyip.com/janusbase/janus")
+    # session = JanusSession(base_url="wss://janusmy.josephgetmyip.com/janusbasews/janus")
+    session = JanusSession(
+        base_url=urljoin(
+            os.getenv("JANUS_HTTP_URL", ""),
+            os.getenv("JANUS_HTTP_BASE_PATH", ""),
+        ),
+        api_secret=os.getenv("JANUS_API_SECRET", ""),
+    )
 
     plugin_handle = JanusEchoTestPlugin()