1import trio 2 3async def main(): 4 async with trio.open_nursery() as nursery: 5 send_channel, receive_channel = trio.open_memory_channel(0) 6 nursery.start_soon(producer, send_channel) 7 nursery.start_soon(consumer, receive_channel) 8 9async def producer(send_channel): 10 async with send_channel: 11 for i in range(3): 12 await send_channel.send(f"message {i}") 13 14async def consumer(receive_channel): 15 async with receive_channel: 16 async for value in receive_channel: 17 print(f"got value {value!r}") 18 19trio.run(main) 20