deleteAllByQuery method

  1. @override
Future<void> deleteAllByQuery(
  1. Query query
)
override

Deletes all entities that match the given query.

Implementation

@override
Future<void> deleteAllByQuery(Query query) async {
  var values = _data.entries
      .where((element) =>
          MapMatcher.evaluate(query.filter, element.value, system))
      .map((e) => EntityIntermediate(e.key, e.value))
      .map((e) => analysis.decode(e));
  await Future.wait(values.map((e) => delete(e)));
}