query method

Stream<Iterable<T>> query({
  1. required QueryTransformer spec,
  2. DocumentReference<Object?>? parent,
})

Same as FirebaseRepository.query but with caching

Implementation

Stream<Iterable<T>> query({
  required QueryTransformer spec,
  DocumentReference? parent,
}) {
  final cache = repository.querySingle(
    spec: spec,
    parent: parent,
    source: Source.cache,
  );
  return ConcatStream([
    Stream.fromFuture(cache),
    repository.query(
      spec: spec,
      parent: parent,
    )
  ]);
}