@override Future<void> removeEventSources(String eventId) async { final prefix = '$eventId|'; eventSources.removeWhere((key, value) => key.startsWith(prefix)); }