ObservableQuery<TParsed> constructor
ObservableQuery<TParsed> (
- {required QueryManager queryManager,
- required WatchQueryOptions<
TParsed> options}
Implementation
ObservableQuery({
required this.queryManager,
required this.options,
}) : queryId = queryManager.generateQueryId().toString() {
if (options.eagerlyFetchResults) {
_latestWasEagerlyFetched = true;
fetchResults();
}
controller = StreamController<QueryResult<TParsed>>.broadcast(
onListen: onListen,
);
}