streamBatchMessages method

Stream<DecodedMessage> streamBatchMessages(
  1. Iterable<Conversation> conversations
)

This exposes a stream of new messages sent to any of the conversations.

Implementation

Stream<DecodedMessage> streamBatchMessages(
        Iterable<Conversation> conversations) =>
    _conversations.streamMessages(conversations);