allMessages method

Stream<SubscriptionMessage> allMessages()

Subscribe to all incoming messages.

Implementation

Stream<SubscriptionMessage> allMessages() => _stream.map(_parse);