ObservableQuery<TParsed> constructor

ObservableQuery<TParsed>({
  1. required QueryManager queryManager,
  2. 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,
  );
}