messages property

Stream<Envelope> get messages

Broadcast stream of messages in this subscription.

Implementation

Stream<Envelope> get messages =>
    _envelopesController.stream.where((envelope) =>
        channels.contains(envelope.channel) ||
        channels.contains(envelope.subscriptionPattern) ||
        channelGroups.contains(envelope.subscriptionPattern));