messageStream property

Stream<WebSocketMessage> get messageStream

Processed message stream. Only messages that pass through all receive interceptors and are not consumed by ACK or topic routing are emitted here.

Implementation

Stream<WebSocketMessage> get messageStream => _messageController.stream;