fix iter_chunks type hint (aio-libs#3230)

dfroger · Aug 31, 2018 · 0b9f694 · 0b9f694
1 parent e38ff2d
commit 0b9f694
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/aiohttp/streams.py b/aiohttp/streams.py
@@ -37,8 +37,15 @@ async def __anext__(self) -> bytes:
         return rv
 
 
-class ChunkTupleAsyncStreamIterator(AsyncStreamIterator):
-    async def __anext__(self) -> bytes:
+class ChunkTupleAsyncStreamIterator:
+
+    def __init__(self, read_func: Callable[[], Awaitable[Tuple[bytes, bool]]]) -> None:
+        self.read_func = read_func
+
+    def __aiter__(self) -> 'ChunkTupleAsyncStreamIterator':
+        return self
+
+    async def __anext__(self) -> Tuple[bytes, bool]:
         rv = await self.read_func()
         if rv == (b'', False):
             raise StopAsyncIteration  # NOQA