如何从输入流异步读取？

import asyncio

async def read_input_stream(input_stream):
    while True:
        data = await input_stream.read(1024)  # 读取输入流的数据块，每次最多读取1024字节
        if not data:  # 如果没有更多数据可用，退出循环
            break
        # 处理读取到的数据，这里只是简单地打印出来
        print(data.decode())

    input_stream.close()  # 关闭输入流

# 使用asyncio库创建一个事件循环
loop = asyncio.get_event_loop()

# 打开输入流，这里使用标准输入作为示例
input_stream = asyncio.StreamReader()
input_protocol = asyncio.StreamReaderProtocol(input_stream)
input_transport, _ = await loop.connect_read_pipe(lambda: input_protocol, asyncio.get_event_loop().child_watcher)

# 调用异步函数来读取输入流
loop.create_task(read_input_stream(input_stream))

# 运行事件循环，直到输入流关闭
loop.run_until_complete(input_transport.wait_closed())