asyncio-channel

Asynchronous channels for communication and synchronization between asyncio coroutines.

from asyncio_channel import create_channel

# Create a new channel.
ch = create_channel()

# Put an item on the channel; block until the item is accepted.
await ch.put(x)

# Take an item from the channel; block until an item is available.
x = await ch.take()

# Do something each time an item is put on the channel.
async for x in ch:
	do_something(x)
	do_something_else(x)
# Iteration stops when the channel is closed and drained.

Also contains several utilities for piping items between channels, mixing multiple input channels, routing messages by topic, and more.