Merge bc788bb into 2d267e7

.github/workflows/test.yml

@@ -63,7 +63,7 @@ jobs:
       - run: pip install .
         if: ${{ matrix.coverage != 'yes' }}
       - run: flake8
-      - run: pytest --cov=fakeredis --cov-branch
+      - run: pytest -v --cov=fakeredis --cov-branch
         if: ${{ matrix.coverage == 'yes' }}
       - run: pytest
         if: ${{ matrix.coverage != 'yes' }}

requirements.in

@@ -1,5 +1,4 @@
 aioredis
-async_generator
 coverage
 flake8
 hypothesis

requirements.txt

@@ -1,13 +1,11 @@
 #
-# This file is autogenerated by pip-compile
+# This file is autogenerated by pip-compile with python 3.8
 # To update, run:
 #
 #    pip-compile requirements.in
 #
 aioredis==1.3.1
     # via -r requirements.in
-async-generator==1.10
-    # via -r requirements.in
 async-timeout==3.0.1
     # via aioredis
 attrs==20.3.0
@@ -42,18 +40,18 @@ pyflakes==2.2.0
     # via flake8
 pyparsing==2.4.7
     # via packaging
-pytest-asyncio==0.14.0
-    # via -r requirements.in
-pytest-cov==2.10.1
-    # via -r requirements.in
-pytest-mock==3.3.1
-    # via -r requirements.in
 pytest==6.1.2
     # via
     #   -r requirements.in
     #   pytest-asyncio
     #   pytest-cov
     #   pytest-mock
+pytest-asyncio==0.15.1
+    # via -r requirements.in
+pytest-cov==2.10.1
+    # via -r requirements.in
+pytest-mock==3.3.1
+    # via -r requirements.in
 redis==3.5.3
     # via -r requirements.in
 six==1.15.0

test/test_aioredis1.py

@@ -3,7 +3,6 @@
 from packaging.version import Version
 import pytest
 import aioredis
-from async_generator import yield_, async_generator
 
 import fakeredis.aioredis
 
@@ -21,7 +20,6 @@
         pytest.param('real', marks=pytest.mark.real)
     ]
 )
-@async_generator
 async def r(request):
     if request.param == 'fake':
         ret = await fakeredis.aioredis.create_redis_pool()
@@ -31,19 +29,18 @@ async def r(request):
         ret = await aioredis.create_redis_pool('redis://localhost')
     await ret.flushall()
 
-    await yield_(ret)
+    yield ret
 
     await ret.flushall()
     ret.close()
     await ret.wait_closed()
 
 
 @pytest.fixture
-@async_generator
 async def conn(r):
     """A single connection, rather than a pool."""
     with await r as conn:
-        await yield_(conn)
+        yield conn
 
 
 async def test_ping(r):

test/test_aioredis2.py

@@ -5,7 +5,6 @@
 import pytest
 import aioredis
 import async_timeout
-from async_generator import yield_, async_generator
 
 import fakeredis.aioredis
 
@@ -28,7 +27,6 @@
         pytest.param('real', marks=pytest.mark.real)
     ]
 )
-@async_generator
 async def r(request):
     if request.param == 'fake':
         fake_server = request.getfixturevalue('fake_server')
@@ -41,19 +39,18 @@ async def r(request):
     if not fake_server or fake_server.connected:
         await ret.flushall()
 
-    await yield_(ret)
+    yield ret
 
     if not fake_server or fake_server.connected:
         await ret.flushall()
     await ret.connection_pool.disconnect()
 
 
 @pytest.fixture
-@async_generator
 async def conn(r):
     """A single connection, rather than a pool."""
     async with r.client() as conn:
-        await yield_(conn)
+        yield conn
 
 
 async def test_ping(r):