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" 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: 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: