streamBatchMessages method
This exposes a stream of new messages sent to any of the conversations
.
Implementation
Stream<DecodedMessage> streamBatchMessages(
Iterable<Conversation> conversations) =>
_conversations.streamMessages(conversations);