async-live-query.ts

import { RecordException } from '@orbit/data';
import { QueryResult } from '../query-result';
import { AsyncRecordCache } from '../async-record-cache';
import { LiveQuery, LiveQuerySettings } from './live-query';

export interface AsyncLiveQuerySettings extends LiveQuerySettings {
  cache: AsyncRecordCache;
}

export class AsyncLiveQuery extends LiveQuery {
  cache: AsyncRecordCache;

  constructor(settings: AsyncLiveQuerySettings) {
    super(settings);
    this.cache = settings.cache;
  }

  get schema() {
    return this.cache.schema;
  }

  executeQuery(
    onNext: (result: QueryResult) => void,
    onError?: (error: RecordException) => void
  ): void {
    this.cache.query(this.query).then(onNext, onError || defaultOnError);
  }
}

function defaultOnError(error: RecordException): void {
  throw error;
}