interceptGatewayMessages method

Stream<GatewayMessage> interceptGatewayMessages(
  1. Shard shard,
  2. Stream<GatewayMessage> messages
)

Intercept GatewayMessages by transforming the messages stream.

Implementation

Stream<GatewayMessage> interceptGatewayMessages(Shard shard, Stream<GatewayMessage> messages) => messages;