@override Stream<Map<String, dynamic>> events() => _e .receiveBroadcastStream() .map((e) => Map<String, dynamic>.from(e as Map)) .where((event) => event.containsKey('host'));