npmpackage.info

Gathering detailed insights and metrics for ordered-read-streams

Other packages similar to ordered-read-streams

get-stream

9.0.1

Get a stream as a string, Buffer, ArrayBuffer or array

@cucumber/message-streams

4.0.1

Streams for reading/writing messages

lazystream

1.0.1

Open Node Streams on demand.

streamx

2.20.2

An iteration of the Node.js core streams with a series of improvements

Gathering detailed insights and metrics for ordered-read-streams

ordered-read-streams

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

2.0.0

MIT

JavaScript

826,527,967 4.3

Installations

npm install ordered-read-streams

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

Published on 10 Oct 2022

View all 1 releases

Developer

gulpjs

Developer Guide

BETA

Module System

Unable to determine the module system for this package.

Min. Node Version

>= 10.13.0

Typescript Support

No

Node Version

16.14.2

NPM Version

8.11.0 Statistics

28 Stars

63 Commits

9 Forks

6 Watching

1 Branches

9 Contributors

Updated on 05 Nov 2023

Languages

JavaScript (100%)

Total Downloads

Cumulative downloads

Total Downloads

826,527,967

Last day

-3.9%

409,847

Compared to previous day

Last week

3.4%

2,249,143

Compared to previous week

Last month

22.4%

8,666,479

Compared to previous month

Last year

-10.7%

99,471,937

Compared to previous year

Daily Downloads

Weekly Downloads

Monthly Downloads

Yearly Downloads

Dependencies

streamx

Dev Dependencies

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

Versions

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