method Stream.merge
Stream.merge(other: Stream<T, E>): Stream<T, E>

Merges two streams by interleaving their results. Both streams must have compatible error types. The merged stream yields values from either stream as they become available.

Examples

Example 1

import { Source } from "anabranch";

const stream1 = Source.from<number, never>(async function* () {
  yield 1;
  yield 3;
});

const stream2 = Source.from<number, never>(async function* () {
  yield 2;
  yield 4;
});

const merged = stream1.merge(stream2);
// Emits values in completion order: 1, 2, 3, 4 (order may vary)

Parameters

other: Stream<T, E>

Return Type

Stream<T, E>

Usage

import { type Stream } from ".";