subscribeToAllMessages method

@override Stream<Map<String, dynamic>> subscribeToAllMessages()

Implementation

@override
Stream<Map<String, dynamic>> subscribeToAllMessages() {
  // Start subscription in JavaScript
  final callback = (JSAny messageData) {
    final map = _jsObjectToMap(messageData);
    _messageController.add(map);
  }.toJS;

  _clientManager.subscribeToAllMessages(callback);

  return _messageController.stream;
}