From 4d6e9de364d1b0c8acb0f2a430281a4a496c25c9 Mon Sep 17 00:00:00 2001 From: Tyler Bowers <43240097+tylerbowers@users.noreply.github.com> Date: Thu, 10 Aug 2023 15:04:15 -0400 Subject: [PATCH 1/3] client fix --- aiocometd/client.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/aiocometd/client.py b/aiocometd/client.py index cb84578..9d3de35 100644 --- a/aiocometd/client.py +++ b/aiocometd/client.py @@ -509,8 +509,7 @@ async def _get_message(self, connection_timeout: Union[int, float]) \ try: done, pending = await asyncio.wait( tasks, - return_when=asyncio.FIRST_COMPLETED, - loop=self._loop) + return_when=asyncio.FIRST_COMPLETED) # cancel all pending tasks for task in pending: From 83f96e492a6ad3830dd34eeb02fff8b41473b754 Mon Sep 17 00:00:00 2001 From: Tyler Bowers <43240097+tylerbowers@users.noreply.github.com> Date: Thu, 10 Aug 2023 15:05:20 -0400 Subject: [PATCH 2/3] long_polling fix --- aiocometd/transports/long_polling.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aiocometd/transports/long_polling.py b/aiocometd/transports/long_polling.py index 33a91fb..08e25d7 100644 --- a/aiocometd/transports/long_polling.py +++ b/aiocometd/transports/long_polling.py @@ -22,7 +22,7 @@ def __init__(self, **kwargs: Any) -> None: super().__init__(**kwargs) #: semaphore to limit the number of concurrent HTTP connections to 2 - self._http_semaphore = asyncio.Semaphore(2, loop=self._loop) + self._http_semaphore = asyncio.Semaphore(2) async def _send_final_payload(self, payload: Payload, *, headers: Headers) -> JsonObject: From 9a48d1d1e2db1dfd9eaa38b8e586eac3a3bbe78c Mon Sep 17 00:00:00 2001 From: Tyler Bowers <43240097+tylerbowers@users.noreply.github.com> Date: Thu, 10 Aug 2023 15:06:17 -0400 Subject: [PATCH 3/3] version bump --- aiocometd/_metadata.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aiocometd/_metadata.py b/aiocometd/_metadata.py index 9a253ff..bcb3ea7 100644 --- a/aiocometd/_metadata.py +++ b/aiocometd/_metadata.py @@ -8,6 +8,6 @@ "Coverage": "https://coveralls.io/github/robertmrk/aiocometd", "Docs": "http://aiocometd.readthedocs.io/" } -VERSION = "0.4.5" +VERSION = "0.4.6" AUTHOR = "Róbert Márki" AUTHOR_EMAIL = "gsmiko@gmail.com"