addQueryResult<TParsed> method

void addQueryResult<TParsed>(
  1. Request request,
  2. String? queryId,
  3. QueryResult<TParsed> queryResult, {
  4. bool fromRebroadcast = false,
})

Add a result to the ObservableQuery specified by queryId, if it exists.

Will maybeRebroadcastQueriesAsync from ObservableQuery.addResult if the cache has flagged the need to.

Queries are registered via setQuery and watchQuery

Implementation

void addQueryResult<TParsed>(
  Request request,
  String? queryId,
  QueryResult<TParsed> queryResult, {
  bool fromRebroadcast = false,
}) {
  final observableQuery = getQuery<TParsed>(queryId);

  if (observableQuery != null && !observableQuery.controller.isClosed) {
    observableQuery.addResult(queryResult, fromRebroadcast: fromRebroadcast);
  }
}