forked from goodboy/tractor
Use plain func for __aiter__()
parent
140956aedb
commit
d6d7fea708
|
@ -57,7 +57,7 @@ class StreamQueue:
|
||||||
async def get(self):
|
async def get(self):
|
||||||
return await self._agen.asend(None)
|
return await self._agen.asend(None)
|
||||||
|
|
||||||
async def __aiter__(self):
|
def __aiter__(self):
|
||||||
return self._agen
|
return self._agen
|
||||||
|
|
||||||
def connected(self):
|
def connected(self):
|
||||||
|
|
Loading…
Reference in New Issue