Preserve an aiohttp streaming response. about aiostream HOT 3 CLOSED

async def main():
    async with aiohttp.ClientSession() as sesh:
        async with sesh.get("https://jsonplaceholder.typicode.com/todos/1") as resp:
            async with stream.preserve(resp.content).stream() as streamer:
                stack = []
                async for line in streamer:
                    stack.append(line)
                    await asyncio.sleep(1)
                    # Some criteria in the middle of content
                    if b"title" in line:
                        break
            preserved_content = stream.iterate(stack) + resp.content
            async with preserved_content.stream() as streamer:
                async for line in streamer:
                    print(line)
                    await asyncio.sleep(1)

@operator(pipable=True)
async def preserve_content(source, items):
    for item in items:
        yield item
    async with stream.preserve(source).stream() as streamer:
        async for item in streamer:
            items.append(item)
            yield item


async def main():
    async with aiohttp.ClientSession() as sesh:
        async with sesh.get("https://jsonplaceholder.typicode.com/todos/1") as resp:
            items = []
            preserved = preserve_content(resp.content, items)
            async with preserved.stream() as streamer:
                async for line in streamer:
                    await asyncio.sleep(1)
                    # Some criteria in the middle of content
                    if b"title" in line:
                        break
            async with preserved.stream() as streamer:
                async for line in streamer:
                    print(line)
                    await asyncio.sleep(1)