concatReadableStreams
import { concatReadableStreams } from "jsr:@ende/streams";function
function concatReadableStreams<T>(...streams: ReadableStream<T>[]): ReadableStream<T>Concatenates multiple ReadableStreams into a single ordered
ReadableStream.
Cancelling the resulting stream will cancel all the input streams.
...streams: ReadableStream<T>[]An iterable of
ReadableStreams to concat.
Returns
A ReadableStream that will emit the concatenated chunks.
Example: Usage
import { concatReadableStreams } from "@ende/streams/concat-readable-streams";
import { assertEquals } from "@ende/assert";
const stream1 = ReadableStream.from([1, 2, 3]);
const stream2 = ReadableStream.from([4, 5, 6]);
const stream3 = ReadableStream.from([7, 8, 9]);
assertEquals(
await Array.fromAsync(concatReadableStreams(stream1, stream2, stream3)),
[1, 2, 3, 4, 5, 6, 7, 8, 9],
);