processReceive method

Future<WebSocketMessage?> processReceive(
  1. WebSocketMessage message
)

Runs message through each interceptor's onReceive. Returns null if suppressed.

Implementation

Future<WebSocketMessage?> processReceive(WebSocketMessage message) async {
  WebSocketMessage? current = message;
  for (final interceptor in _interceptors) {
    if (current == null) return null;
    current = await interceptor.onReceive(current);
  }
  return current;
}