Merge branch 'release/3.3.3'

Author: wolph

.github/workflows/main.yml

@@ -8,10 +8,10 @@ on:
 jobs:
   build:
     runs-on: ubuntu-latest
-    timeout-minutes: 2
+    timeout-minutes: 4
     strategy:
       matrix:
-        python-version: ['3.7', '3.8', '3.9', '3.10']
+        python-version: ['3.7', '3.8', '3.9', '3.10', '3.11-dev']
 
     steps:
       - uses: actions/checkout@v2

python_utils/__about__.py

@@ -7,4 +7,4 @@
 )
 __url__: str = 'https://github.com/WoLpH/python-utils'
 # Omit type info due to automatic versioning script
-__version__ = '3.3.2'
+__version__ = '3.3.3'

python_utils/generators.py

@@ -6,7 +6,7 @@
 
 
 async def abatcher(
-    generator: types.AsyncGenerator,
+    generator: types.AsyncIterator,
     batch_size: types.Optional[int] = None,
     interval: types.Optional[types.delta_type] = None,
 ):
@@ -33,7 +33,10 @@ async def abatcher(
     while True:
         try:
             done, pending = await asyncio.wait(
-                pending or [generator.__anext__()],
+                pending
+                or [
+                    asyncio.create_task(generator.__anext__()),  # type: ignore
+                ],
                 timeout=interval_s,
                 return_when=asyncio.FIRST_COMPLETED,
             )

tox.ini

@@ -1,5 +1,5 @@
 [tox]
-envlist = black, py37, py38, py39, py310, pypy3, flake8, docs
+envlist = black, py37, py38, py39, py310, py311, pypy3, flake8, docs
 skip_missing_interpreters = True
 
 [testenv]
@@ -8,6 +8,7 @@ basepython =
     py38: python3.8
     py39: python3.9
     py310: python3.10
+    py311: python3.11
     pypy: pypy
 
 setenv = PY_IGNORE_IMPORTMISMATCH=1