lives<R> method

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

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 {
    final url = currentSource(source);
    Timer.periodic(const Duration(milliseconds: 3000), (timer) async {
      final reference = await database.get(url);
      final data = reference.data;
      final code = reference.statusCode;
      if ((code == 200 || code == api.status.ok) && data is List<dynamic>) {
        List<T> result = data.map((item) {
          return build(item);
        }).toList();
        controller.add(
          response.copy(result: result),
        );
      } else {
        final error = "Data unmodified [${reference.statusCode}]";
        controller.addError(
          response.copy(snapshot: reference, error: error),
        );
      }
    });
  } catch (_) {
    controller.addError(_);
  }

  return controller.stream;
}