subscribeToAllMessages method

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

Implementation

@override
Stream<Map<String, dynamic>> subscribeToAllMessages() {
  final StreamController<Map<String, dynamic>> controller = StreamController<Map<String, dynamic>>();

  methodChannel.invokeMethod('subscribeToAllMessages');

  methodChannel.setMethodCallHandler((MethodCall call) async {
    if (call.method == 'onMessageReceived') {
      final Map<String, dynamic> message = Map<String, dynamic>.from(call.arguments);
      print('Message Received: $message');
      controller.add(message);
    }
  });

  return controller.stream;
}