@override Stream<Map<String, dynamic>> get onMessage { return FirebaseMessaging.onMessage .where((message) => message.isAirflexMessage) .map((message) => _extractDataWithMessage(message)); }