( other: IStreamBuilder<KeyValue<K, V2>>, )
| 342 | * @param other - The other stream to join with |
| 343 | */ |
| 344 | export function rightJoin< |
| 345 | K, |
| 346 | V1 extends T extends KeyValue<infer _KT, infer VT> ? VT : never, |
| 347 | V2, |
| 348 | T, |
| 349 | >( |
| 350 | other: IStreamBuilder<KeyValue<K, V2>>, |
| 351 | ): PipedOperator<T, KeyValue<K, [V1 | null, V2]>> { |
| 352 | return join(other, `right`) as unknown as PipedOperator< |
| 353 | T, |
| 354 | KeyValue<K, [V1 | null, V2]> |
| 355 | > |
| 356 | } |
| 357 | |
| 358 | /** |
| 359 | * Joins two input streams (full join) |