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,
);
}