interceptShardMessages method
- Shard shard,
- Stream<
ShardMessage> messages
Intercept ShardMessage
s by transforming the messages
stream.
Implementation
Stream<ShardMessage> interceptShardMessages(Shard shard, Stream<ShardMessage> messages) => messages;