Method sendChangesToD2

packages/db/src/query/effect.ts:705–719

* Send changes to the D2 input for the given alias. * Returns the number of multiset entries sent.

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

   * Returns the number of multiset entries sent.
   */
  private sendChangesToD2(
    alias: string,
    changes: Array<ChangeMessage<any, string | number>>,
  ): number {
    if (this.disposed || !this.inputs || !this.graph) return 0

    const input = this.inputs[alias]
    if (!input) return 0

    // Filter duplicates per alias
    const sentKeys = this.sentToD2KeysByAlias.get(alias)!
    const filtered = filterDuplicateInserts(changes, sentKeys)

    return sendChangesToInput(input, filtered)
  }

  /**
   * Run the D2 graph until quiescence, then emit accumulated events once.