lives<R> method

  1. @override
Stream<Response<T>> lives<R>({
  1. bool onlyUpdatedData = false,
  2. Map<String, dynamic>? extra,
  3. R? source(
    1. R parent
    )?,
})
override

Implementation

@override
Stream<Response<T>> lives<R>({
  bool onlyUpdatedData = false,
  Map<String, dynamic>? extra,
  R? Function(R parent)? source,
}) {
  final controller = StreamController<Response<T>>();
  final response = Response<T>();
  try {
    _source(source).onValue.listen((result) {
      if (result.snapshot.exists) {
        List<T> list = result.snapshot.children.map((e) {
          return build(e.value);
        }).toList();
        controller.add(response.copy(result: list));
      } else {
        controller.addError("Data not found!");
      }
    });
  } catch (_) {
    controller.addError(_);
  }

  return controller.stream;
}