Method handleSourceChanges

packages/db/src/query/effect.ts:637–643

Handle incoming changes from a source collection

(
    alias: string,
    changes: Array<ChangeMessage<any, string | number>>,
  )

  /** Handle incoming changes from a source collection */
  private handleSourceChanges(
    alias: string,
    changes: Array<ChangeMessage<any, string | number>>,
  ): void {
    this.sendChangesToD2(alias, changes)
    this.scheduleGraphRun(alias)
  }

  /**
   * Schedule a graph run via the transaction-scoped scheduler.