cashier_admin_app/node_modules/@sindresorhus/merge-streams
YeMingfei666 dd4f5938da first 2024-09-10 10:49:47 +08:00
..
index.d.ts first 2024-09-10 10:49:47 +08:00
index.js first 2024-09-10 10:49:47 +08:00
license first 2024-09-10 10:49:47 +08:00
package.json first 2024-09-10 10:49:47 +08:00
readme.md first 2024-09-10 10:49:47 +08:00

readme.md

merge-streams

Merge multiple streams into a unified stream

Install

npm install @sindresorhus/merge-streams

Usage

import mergeStreams from '@sindresorhus/merge-streams';

const stream = mergeStreams([streamA, streamB]);

for await (const chunk of stream) {
	console.log(chunk);
	//=> 'A1'
	//=> 'B1'
	//=> 'A2'
	//=> 'B2'
}

API

mergeStreams(streams: stream.Readable[]): MergedStream

Merges an array of readable streams and returns a new readable stream that emits data from the individual streams as it arrives.

If you provide an empty array, it returns an already-ended stream.

MergedStream

Type: stream.Readable

A single stream combining the output of multiple streams.

MergedStream.add(stream: stream.Readable): void

Pipe a new readable stream.

Throws if MergedStream has already ended.

MergedStream.remove(stream: stream.Readable): boolean

Unpipe a stream previously added using either mergeStreams(streams) or MergedStream.add(stream).

Returns false if the stream was not previously added, or if it was already removed by MergedStream.remove(stream).

The removed stream is not automatically ended.