query method
Stream<Iterable<T> >
query({
- required QueryTransformer<
T> spec, - required String type,
- DocumentReference<
Object?> ? parent,
Same as FirebaseRepository.query but with caching
Implementation
Stream<Iterable<T>> query({
required QueryTransformer<T> spec,
required String type,
DocumentReference? parent,
}) {
final cache = repository.querySingle(
spec: spec,
type: type,
parent: parent,
source: Source.cache,
);
return ConcatStream([
Stream.fromFuture(cache),
repository.query(
spec: spec,
type: type,
parent: parent,
)
]);
}