Skip to content
Snippets Groups Projects
Commit 6761c173 authored by davebshow's avatar davebshow
Browse files

removed unneeded stuff on the iterator

parent 7ef93a6b
No related merge requests found
......@@ -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):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment