interceptShardMessages method

  1. @mustCallSuper
Stream<ShardMessage> interceptShardMessages(
  1. Shard shard,
  2. Stream<ShardMessage> messages
)

Intercept ShardMessages by transforming the messages stream.

Implementation

@mustCallSuper
Stream<ShardMessage> interceptShardMessages(Shard shard, Stream<ShardMessage> messages) =>
    _states[shard.client]?.interceptShardMessages(shard, messages) ?? messages;