streamMessages method

Stream<DecodedMessage> streamMessages(
  1. Conversation conversation
)

This exposes a stream of new messages sent to the conversation. For streaming multiple conversations, see streamBatchMessages.

Implementation

Stream<DecodedMessage> streamMessages(Conversation conversation) =>
    _conversations.streamMessages([conversation]);