diff --git a/aiocometd/_metadata.py b/aiocometd/_metadata.py index 9a253ff..8b3c4a9 100644 --- a/aiocometd/_metadata.py +++ b/aiocometd/_metadata.py @@ -2,12 +2,11 @@ TITLE = "aiocometd" DESCRIPTION = "CometD client for asyncio" KEYWORDS = "asyncio aiohttp comet cometd bayeux push streaming" -URL = "https://github.com/robertmrk/aiocometd" +URL = "https://github.com/hyperscience/aiocometd" PROJECT_URLS = { "CI": "https://travis-ci.org/robertmrk/aiocometd", "Coverage": "https://coveralls.io/github/robertmrk/aiocometd", "Docs": "http://aiocometd.readthedocs.io/" } -VERSION = "0.4.5" -AUTHOR = "Róbert Márki" -AUTHOR_EMAIL = "gsmiko@gmail.com" +VERSION = "0.4.5+hs0" +AUTHOR = "Hyperscience" diff --git a/aiocometd/client.py b/aiocometd/client.py index cb84578..de4a6fa 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: @@ -546,7 +545,7 @@ async def _wait_connection_timeout(self, timeout: Union[int, float]) \ try: await asyncio.wait_for( self._transport.wait_for_state(TransportState.CONNECTED), - timeout, loop=self._loop + timeout ) except asyncio.TimeoutError: break diff --git a/aiocometd/transports/base.py b/aiocometd/transports/base.py index be6114f..4d91c17 100644 --- a/aiocometd/transports/base.py +++ b/aiocometd/transports/base.py @@ -432,7 +432,7 @@ def _start_connect_task(self, coro: Awaitable[JsonObject]) \ :param coro: Coroutine :return: Future """ - self._connect_task = asyncio.ensure_future(coro, loop=self._loop) + self._connect_task = asyncio.ensure_future(coro) self._connect_task.add_done_callback(self._connect_done) return self._connect_task 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: diff --git a/aiocometd/utils.py b/aiocometd/utils.py index f1e9dcb..2fa13e5 100644 --- a/aiocometd/utils.py +++ b/aiocometd/utils.py @@ -23,7 +23,7 @@ def defer(coro_func: CoroFunction, delay: Union[int, float, None] = None, *, async def wrapper(*args: Any, **kwargs: Any) -> Any: \ # pylint: disable=missing-docstring if delay: - await asyncio.sleep(delay, loop=loop) # type: ignore + await asyncio.sleep(delay) # type: ignore return await coro_func(*args, **kwargs) return wrapper diff --git a/setup.py b/setup.py index 0d79e57..1ae7d1c 100644 --- a/setup.py +++ b/setup.py @@ -44,19 +44,17 @@ def read(file_path): classifiers=[ "Programming Language :: Python", "Programming Language :: Python :: 3", - "Programming Language :: Python :: 3.6", + "Programming Language :: Python :: 3.10", "Programming Language :: Python :: Implementation :: CPython", "Framework :: AsyncIO", "License :: OSI Approved :: MIT License" ], keywords=metadata["KEYWORDS"], - author=metadata["AUTHOR"], - author_email=metadata["AUTHOR_EMAIL"], url=metadata["URL"], project_urls=metadata["PROJECT_URLS"], license="MIT", packages=find_packages(exclude=("tests*", "examples")), - python_requires=">=3.6.0", + python_requires=">=3.10.0", install_requires=INSTALL_REQUIRES, tests_require=TESTS_REQUIRE, extras_require={ diff --git a/tox.ini b/tox.ini index b9d61e4..6032ffb 100644 --- a/tox.ini +++ b/tox.ini @@ -1,5 +1,5 @@ [tox] -envlist = py36,py37 +envlist = py310,py311,py312 [testenv] passenv = TRAVIS TRAVIS_*