code: async def close(self):
          
          if self._pool is not None and not isinstance(self.connection, aioredis.Redis):
              self._pool.close()
              await self._pool.wait_closed()
          self._pool = None
docs: Closes connection and resets pool