@override Future<void> removeEventSources(String eventId) async { await _eventSourceStore.delete( _database, finder: sembast.Finder(filter: sembast.Filter.equals('eventId', eventId)), ); }