Add aclose() to asyncio.client.Pipeline

Author: kristjanvalur

redis/asyncio/client.py

@@ -1201,6 +1201,10 @@ async def reset(self):
             await self.connection_pool.release(self.connection)
             self.connection = None
 
+    async def aclose(self) -> None:
+        """Alias for reset(), a standard method name for cleanup"""
+        await self.reset()
+
     def multi(self):
         """
         Start a transactional block of the pipeline after WATCH commands

tests/test_asyncio/test_pipeline.py

@@ -2,6 +2,7 @@
 import redis
 from tests.conftest import skip_if_server_version_lt
 
+from .compat import aclosing, mock
 from .conftest import wait_for_command
 
 
@@ -286,6 +287,24 @@ async def test_watch_reset_unwatch(self, r):
             assert unwatch_command is not None
             assert unwatch_command["command"] == "UNWATCH"
 
+    @pytest.mark.onlynoncluster
+    async def test_aclose_is_reset(self, r):
+        async with r.pipeline() as pipe:
+            called = 0
+
+            async def mock_reset():
+                nonlocal called
+                called += 1
+
+            with mock.patch.object(pipe, "reset", mock_reset):
+                await pipe.aclose()
+                assert called == 1
+
+    @pytest.mark.onlynoncluster
+    async def test_aclosing(self, r):
+        async with aclosing(r.pipeline()):
+            pass
+
     @pytest.mark.onlynoncluster
     async def test_transaction_callable(self, r):
         await r.set("a", 1)