(
id: number,
inputA: DifferenceStreamReader<[K, V1]>,
inputB: DifferenceStreamReader<[K, V2]>,
output: DifferenceStreamWriter<any>,
mode: JoinType = `inner`,
)
| 71 | #mode: JoinType |
| 72 | |
| 73 | constructor( |
| 74 | id: number, |
| 75 | inputA: DifferenceStreamReader<[K, V1]>, |
| 76 | inputB: DifferenceStreamReader<[K, V2]>, |
| 77 | output: DifferenceStreamWriter<any>, |
| 78 | mode: JoinType = `inner`, |
| 79 | ) { |
| 80 | super(id, inputA, inputB, output) |
| 81 | this.#mode = mode |
| 82 | } |
| 83 | |
| 84 | run(): void { |
| 85 | // Build deltas from input messages |
nothing calls this directly
no outgoing calls
no test coverage detected