getOneStream method

  1. @override
Stream<T?> getOneStream(
  1. bool test(
    1. T value
    )
)

Implementation

@override
Stream<T?> getOneStream(bool Function(T value) test) async* {
  await for (var item in getAllStream()) {
    if (test(item)) {
      yield item;
      return;
    }
  }
  yield null;
}