Neatly Packaged Modules

    duplexer2-unwrappable

    0.1.4 • Public • Published

    duplexer2-unwrappable

    Build Status Coverage Status Dependency Status devDependency Status Downloads

    Like duplexer2 but unwrappable

    NPM

    var stream = require("stream");
     
    var duplexer2 = require("duplexer2-unwrappable");
     
    var writable = new stream.Writable({objectMode: true}),
        readable = new stream.Readable({objectMode: true});
     
    writable._write = function _write(input, encoding, done) {
      if (readable.push(input)) {
        return done();
      } else {
        readable.once("drain", done);
      }
    };
     
    readable._read = function _read(n) {
      // no-op
    };
     
    // simulate the readable thing closing after a bit
    writable.once("finish", function() {
      setTimeout(function() {
        readable.push(null);
      }, 500);
    });
     
    var duplex = duplexer2(writable, readable);
     
    duplex.on("data", function(e) {
      console.log("got data", JSON.stringify(e));
    });
     
    duplex.on("finish", function() {
      console.log("got finish event");
    });
     
    duplex.on("end", function() {
      console.log("got end event");
    });
     
    duplex.write("oh, hi there", function() {
      console.log("finished writing");
    });
     
    duplex.end(function() {
      console.log("finished ending");
    });
    got data "oh, hi there"
    finished writing
    got finish event
    finished ending
    got end event
    

    Overview

    This is a reimplementation of duplexer using the Streams3 API which is standard in Node as of v4. Everything largely works the same.

    Installation

    Available via npm:

    $ npm i duplexer2-unwrappable
    

    API

    duplexer2

    Creates a new DuplexWrapper object, which is the actual class that implements most of the fun stuff. All that fun stuff is hidden. DON'T LOOK. now exposed so you can unwrap streams and avoid having closures bind streams together forever.

    new duplexer2([options], writable, readable)
    const duplex = new duplexer2(new stream.Writable(), new stream.Readable());

    Arguments

    • options - an object specifying the regular stream.Duplex options, as well as the properties described below.
    • writable - a writable stream
    • readable - a readable stream

    Options

    • bubbleErrors - a boolean value that specifies whether to bubble errors from the underlying readable/writable streams. Default is true.

    Instance Methods

    • unbind - unbinds the duplexer2 instance from the writable and readable stream methods, allowing the underlying streams to be re-used.

    License

    3-clause BSD. A copy is included with the source.

    Contact

    Install

    npm i duplexer2-unwrappable

    DownloadsWeekly Downloads

    1

    Version

    0.1.4

    License

    BSD-3-Clause

    Last publish

    Collaborators

    • doublerebel