interceptShardMessages method

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

Intercept ShardMessages by transforming the messages stream.

Implementation

Stream<ShardMessage> interceptShardMessages(Shard shard, Stream<ShardMessage> messages) => messages;