MCPcopy Create free account
hub / github.com/TanStack/db / emitInnerResults

Method emitInnerResults

packages/db-ivm/src/operators/join.ts:130–139  ·  view source on GitHub ↗
(
    deltaA: Index<K, V1>,
    deltaB: Index<K, V2>,
    results: MultiSet<any>,
  )

Source from the content-addressed store, hash-verified

128 }
129
130 private emitInnerResults(
131 deltaA: Index<K, V1>,
132 deltaB: Index<K, V2>,
133 results: MultiSet<any>,
134 ): void {
135 // Emit the three standard delta terms: ΔA⋈B_old, A_old⋈ΔB, ΔA⋈ΔB
136 if (deltaA.size > 0) results.extend(deltaA.join(this.#indexB))
137 if (deltaB.size > 0) results.extend(this.#indexA.join(deltaB))
138 if (deltaA.size > 0 && deltaB.size > 0) results.extend(deltaA.join(deltaB))
139 }
140
141 private emitLeftOuterResults(
142 deltaA: Index<K, V1>,

Callers 1

runMethod · 0.95

Calls 2

extendMethod · 0.80
joinMethod · 0.45

Tested by

no test coverage detected