From 6761c173cc591ae5747af307a3c9427ab782f1ba Mon Sep 17 00:00:00 2001
From: davebshow <davebshow@gmail.com>
Date: Wed, 6 Jul 2016 10:14:49 -0400
Subject: [PATCH] removed unneeded stuff on the iterator
---
goblin/driver/connection.py | 11 +----------
1 file changed, 1 insertion(+), 10 deletions(-)
diff --git a/goblin/driver/connection.py b/goblin/driver/connection.py
index 2cbf049..1653088 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):
--
GitLab