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