Installations

npm install @sindresorhus/merge-streams

Score

99.4

Supply Chain

83.3

Quality

81.7

Maintenance

100

Vulnerability

100

License

Pull Requests

Open

0

Total

23

Closed

0

Merged

23

Issues

Open

0

Total

21

Closed

21

Releases

11

v4.0.0

Published on 04 May 2024

v3.0.0

Published on 20 Feb 2024

v2.3.0

Published on 19 Feb 2024

v2.2.1

Published on 14 Feb 2024

v2.2.0

Published on 12 Feb 2024

v2.1.0

Published on 03 Feb 2024

View all 11 releases

Developer

sindresorhus

Developer Guide

BETA

Module System

ESM

Min. Node Version

>=18

Typescript Support

Yes

Node Version

20.12.2

NPM Version

10.6.0 Statistics

54 Stars

37 Commits

4 Watching

1 Branches

2 Contributors

Updated on 15 Nov 2024

Languages

JavaScript (97.45%)

TypeScript (2.55%)

Total Downloads

Cumulative downloads

Total Downloads

184,466,906

Last day

-3.6%

1,223,129

Compared to previous day

Last week

2.4%

6,857,920

Compared to previous week

Last month

9.4%

28,646,375

Compared to previous month

Last year

18,876.3%

183,499,910

Compared to previous year

Daily Downloads

Weekly Downloads

Monthly Downloads

Yearly Downloads

Dev Dependencies

7

@types/node ava c8 tempfile tsd typescript xo

Versions

merge-streams

Merge multiple streams into a unified stream

Install

1npm install @sindresorhus/merge-streams

Usage

1import mergeStreams from '@sindresorhus/merge-streams';
2
3const stream = mergeStreams([streamA, streamB]);
4
5for await (const chunk of stream) {
6	console.log(chunk);
7	//=> 'A1'
8	//=> 'B1'
9	//=> 'A2'
10	//=> 'B2'
11}

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, the stream remains open but can be manually ended.

`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): Promise<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.

No vulnerabilities found.

10

Dangerous-Workflow

Determines if the project's GitHub Action workflows avoid dangerous patterns.

10

Security-Policy

Determines if the project has published a security policy.

10

Binary-Artifacts

Determines if the project has generated executable (binary) artifacts in the source repository.

10

License

Determines if the project has defined a license.

10

Vulnerabilities

Determines if the project has open, known unfixed vulnerabilities.

6

Code-Review

Determines if the project requires human code review before pull requests (aka merge requests) are merged.

0

Maintained

Determines if the project is "actively maintained".

0

Pinned-Dependencies

Determines if the project has declared and pinned the dependencies of its build process.

0

Token-Permissions

Determines if the project's workflows follow the principle of least privilege.

0

CII-Best-Practices

Determines if the project has an OpenSSF (formerly CII) Best Practices Badge.

0

Fuzzing

Determines if the project uses fuzzing.

0

Branch-Protection

Determines if the default and release branches are protected with GitHub's branch protection settings.

0

SAST

Determines if the project uses static code analysis.

Score

4.6

/10

Last Scanned on 2024-11-18

The Open Source Security Foundation is a cross-industry collaboration to improve the security of open source software (OSS). The Scorecard provides security health metrics for open source projects.

Learn More