Async iterable for consuming messages instead of callback

[purpleP]

HI, I think this would be a nice feature, because it would open all benefits of iterables in message processing code. It's basically what Scala's Akka and other stream libraries (rx I think is another example of this) are doing.
By the way if you need any help maintaining I'll be glad to help.