diff --git a/goblin/driver/connection.py b/goblin/driver/connection.py index 3d37388e1b7c0cb48366ed42080446d5bd71f073..5abf371da11ce1f685fd49a99de3e813d596a0db 100644 --- a/goblin/driver/connection.py +++ b/goblin/driver/connection.py @@ -6,7 +6,7 @@ class AsyncResponseIter: def __init__(self, response_queue, loop, conn, username, password, processor, session): - self._response_queue = self.response_queues + self._response_queue = self.response_queue self._loop = loop self._conn = conn self._force_close = self._conn.force_close