diff --git a/goblin/driver/connection.py b/goblin/driver/connection.py index 2cbf049e6503ea825af90dbbcde1f2b2f8063cc0..1653088e31bdc20cf4644f4a8b1461c61c6b8659 100644 --- a/goblin/driver/connection.py +++ b/goblin/driver/connection.py @@ -16,13 +16,9 @@ Message = collections.namedtuple( class AsyncResponseIter: - def __init__(self, response_queue, loop, conn, username, password, - processor, session): + def __init__(self, response_queue, loop: self._response_queue = response_queue self._loop = loop - self._conn = conn - self._force_close = self._conn.force_close - self._force_release = self._conn.force_release async def __aiter__(self): return self @@ -42,11 +38,6 @@ class AsyncResponseIter: message = await self._response_queue.get() return message - async def close(self): - if self._conn: - await self._conn.close() - self._conn = None - class AbstractConnection(abc.ABC):