Have ideas to improve npm?Join in the discussion! »

    ordered-read-streams

    1.0.1 • Public • Published

    ordered-read-streams NPM version Build Status

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

    Installation

    npm install ordered-read-streams

    Overview

    ordered-read-streams handles all data/errors from input streams in parallel, but emits data/errors in strict order in which streams are passed to constructor. This is objectMode = true stream.

    Example

    var through = require('through2');
    var Ordered = require('ordered-read-streams');
     
    var s1 = through.obj(function (data, enc, next) {
      var self = this;
      setTimeout(function () {
        self.push(data);
        next();
      }, 200)
    });
    var s2 = through.obj(function (data, enc, next) {
      var self = this;
      setTimeout(function () {
        self.push(data);
        next();
      }, 30)
    });
    var s3 = through.obj(function (data, enc, next) {
      var self = this;
      setTimeout(function () {
        self.push(data);
        next();
      }, 100)
    });
     
    var streams = new Ordered([s1, s2, s3]);
    streams.on('data', function (data) {
      console.log(data);
    })
     
    s1.write('stream 1');
    s1.end();
     
    s2.write('stream 2');
    s2.end();
     
    s3.write('stream 3');
    s3.end();

    Ouput will be:

    stream 1
    stream 2
    stream 3
    

    Licence

    MIT

    Keywords

    none

    Install

    npm i ordered-read-streams

    DownloadsWeekly Downloads

    1,755,490

    Version

    1.0.1

    License

    MIT

    Last publish

    Collaborators

    • avatar
    • avatar