We added two levels of abstractions for this purpose: - A Stream iterates over a channel - A Channel implements: `channel.send` and `channel.__aiter__`. - A

We added two levels of abstractions for this purpose: - A Stream iterates over a channel - A Channel implements: `channel.send` and `channel.__aiter__`. - A topic is a "named" channel backed by a Kafka topic - Further the topic is backed by a Transport - Transport is very Kafka specific To implement support for AMQP the idea is you only need to implement a custom channel. If you open an issue we can consider how to best implement it.