getQueryStream method

  1. @override
Stream<List<T>> getQueryStream(
  1. bool test(
    1. T value
    )
)

Implementation

@override
Stream<List<T>> getQueryStream(bool Function(T value) test) async* {
  final list = <T>[];

  await for (var item in getAllStream()) {
    if (test(item)) {
      list.add(item);
    }
  }
  yield list;
}