@override Stream<Map<dynamic, dynamic>> get rawEventStream { return _events .receiveBroadcastStream() .where((e) => e is Map) .cast<Map<dynamic, dynamic>>(); }