messages property

Stream<ShardMessage> messages

A stream of messages received from all shards.

Implementation

// Adapting _messagesController.stream to a broadcast stream instead of
// simply making _messagesController a broadcast controller means events will
// be buffered until this field is initialized, which prevents events from
// being dropped during the connection process.
late final Stream<ShardMessage> messages = _messagesController.stream.asBroadcastStream();