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