npmpackage.info

Gathering detailed insights and metrics for ordered-read-streams

Other packages similar to ordered-read-streams

ordered-kv-tuple-stream

1.2.5

Aligns multiple ordered k/v readable streams into one

Gathering detailed insights and metrics for ordered-read-streams

ordered-read-streams - 2.0.0 | npmpackage.info

ordered-read-streams

Combines array of streams into one Readable stream in strict order.

2.0.0

MIT

JavaScript

7.55 kB

4.3

Installations

npm install ordered-read-streams

Developer Guide

BETA

Typescript

No

Module System

N/A

Min. Node Version

>= 10.13.0

Node Version

16.14.2

NPM Version

8.11.0 Pull Requests

Open

0

Total

15

Closed

3

Merged

12

Issues

Open

0

Total

14

Closed

14

Releases

ordered-read-streams v2.0.0

v2.0.0

Updated on Oct 10, 2022

View All 1 releases

Languages

JavaScript

JavaScript (100%)

Developer

gulpjs

Download Statistics

Total Downloads

Last Day

Last Week

Last Month

Last Year

GitHub Statistics

MIT License

28 Stars

63 Commits

9 Forks

5 Watchers

1 Branches

9 Contributors

Updated on Nov 05, 2023

Maintainers

View All 9 Contributors

Package Meta Information

Latest Version

2.0.0

Package Id

ordered-read-streams@2.0.0

Unpacked Size

7.55 kB

Size

2.90 kB

File Count

NPM Version

8.11.0

Node Version

16.14.2

Total Downloads

Cumulative downloads

Total Downloads

NaN

Last Day

NaN

Compared to previous day

Last Week

NaN

Compared to previous week

Last Month

NaN

Compared to previous month

Last Year

NaN

Compared to previous year

Weekly Downloads

Monthly Downloads

Yearly Downloads

Dependencies

streamx

Dev Dependencies

eslint eslint-config-gulp eslint-plugin-node expect mocha nyc readable-stream

ordered-read-streams

Combines array of streams into one Readable stream in strict order.

Usage

1var { Readable } = require('streamx');
2var ordered = require('ordered-read-streams');
3
4var s1 = new Readable({
5  read: function (cb) {
6    var self = this;
7    if (self.called) {
8      self.push(null);
9      return cb(null);
10    }
11    setTimeout(function () {
12      self.called = true;
13      self.push('stream 1');
14      cb(null);
15    }, 200);
16  },
17});
18var s2 = new Readable({
19  read: function (cb) {
20    var self = this;
21    if (self.called) {
22      self.push(null);
23      return cb(null);
24    }
25    setTimeout(function () {
26      self.called = true;
27      self.push('stream 2');
28      cb(null);
29    }, 30);
30  },
31});
32var s3 = new Readable({
33  read: function (cb) {
34    var self = this;
35    if (self.called) {
36      self.push(null);
37      return cb(null);
38    }
39    setTimeout(function () {
40      self.called = true;
41      self.push('stream 3');
42      cb(null);
43    }, 100);
44  },
45});
46
47var readable = ordered([s1, s2, s3]);
48readable.on('data', function (data) {
49  console.log(data);
50  // Logs:
51  // stream 1
52  // stream 2
53  // stream 3
54});

API

`ordered(streams, [options])`

Takes an array of Readable streams and produces a single OrderedReadable stream that will consume the provided streams in strict order. The produced Readable stream respects backpressure on itself and any provided streams.

`orderedReadable.addSource(stream)`

The returned Readable stream has an addSource instance function that takes appends a Readable stream to the list of source streams that the OrderedReadable is reading from.

License

MIT

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.3

/10

Last Scanned on 2025-07-07

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