Function innerJoin

packages/db-ivm/src/operators/join.ts:290–302

(
  other: IStreamBuilder<KeyValue<K, V2>>,
)

 * @param other - The other stream to join with
 */
export function innerJoin<
  K,
  V1 extends T extends KeyValue<infer _KT, infer VT> ? VT : never,
  V2,
  T,
>(
  other: IStreamBuilder<KeyValue<K, V2>>,
): PipedOperator<T, KeyValue<K, [V1, V2]>> {
  return join(other, `inner`) as unknown as PipedOperator<
    T,
    KeyValue<K, [V1, V2]>
  >
}

/**
 * Joins two input streams (anti join)