如何在Python3中将异步生成流转换为类文件对象？

import asyncio

class AsyncGeneratorToFile:
    def __init__(self, async_generator):
        self.async_generator = async_generator
        self.buffer = b""
        self.eof = False

    async def read(self, size=-1):
        if self.eof:
            return b""
        
        while size < 0 or len(self.buffer) < size:
            try:
                chunk = await self.async_generator.__anext__()
                self.buffer += chunk
            except StopAsyncIteration:
                self.eof = True
                break
        
        if size < 0:
            data = self.buffer
            self.buffer = b""
        else:
            data = self.buffer[:size]
            self.buffer = self.buffer[size:]
        
        return data

    async def readline(self):
        if self.eof:
            return b""
        
        while b"\n" not in self.buffer:
            try:
                chunk = await self.async_generator.__anext__()
                self.buffer += chunk
            except StopAsyncIteration:
                self.eof = True
                break
        
        index = self.buffer.find(b"\n") + 1
        data = self.buffer[:index]
        self.buffer = self.buffer[index:]
        
        return data

    async def __aiter__(self):
        return self

    async def __anext__(self):
        data = await self.readline()
        if not data:
            raise StopAsyncIteration
        return data

# 示例用法
async def async_generator():
    yield b"Hello, "
    await asyncio.sleep(1)
    yield b"world!"
    await asyncio.sleep(1)
    yield b"Goodbye."

async def main():
    async with AsyncGeneratorToFile(async_generator()) as file:
        data = await file.read()
        print(data.decode())
        
        line = await file.readline()
        print(line.decode())
        
        async for line in file:
            print(line.decode())

asyncio.run(main())