getOneStream method

Stream<T?> getOneStream(
  1. bool test(
    1. T value
    ), {
  2. int? parentId,
})

Get One With StreamBox<T?>

Implementation

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