Method countInner

packages/db-ivm/src/operators/count.ts:16–22

(vals: Array<[V, number]>)

    output: DifferenceStreamWriter<[K, number]>,
  ) {
    const countInner = (vals: Array<[V, number]>): Array<[number, number]> => {
      let totalCount = 0
      for (const [_, diff] of vals) {
        totalCount += diff
      }
      return [[totalCount, 1]]
    }

    super(id, inputA, output, countInner)
  }