Sha256: 706eb5a5e229887aa4bc34bdd3c0a9c0a413e4e26d6c09ae182150646eab1a86

Contents?: true

Size: 1.28 KB

Versions: 8

Compression:

Stored size: 1.28 KB

Contents

/* */ 
(function(process) {
  module.exports = Duplex;
  var objectKeys = Object.keys || function(obj) {
    var keys = [];
    for (var key in obj)
      keys.push(key);
    return keys;
  };
  var util = require('core-util-is');
  util.inherits = require('inherits');
  var Readable = require('./_stream_readable');
  var Writable = require('./_stream_writable');
  util.inherits(Duplex, Readable);
  forEach(objectKeys(Writable.prototype), function(method) {
    if (!Duplex.prototype[method])
      Duplex.prototype[method] = Writable.prototype[method];
  });
  function Duplex(options) {
    if (!(this instanceof Duplex))
      return new Duplex(options);
    Readable.call(this, options);
    Writable.call(this, options);
    if (options && options.readable === false)
      this.readable = false;
    if (options && options.writable === false)
      this.writable = false;
    this.allowHalfOpen = true;
    if (options && options.allowHalfOpen === false)
      this.allowHalfOpen = false;
    this.once('end', onend);
  }
  function onend() {
    if (this.allowHalfOpen || this._writableState.ended)
      return;
    process.nextTick(this.end.bind(this));
  }
  function forEach(xs, f) {
    for (var i = 0,
        l = xs.length; i < l; i++) {
      f(xs[i], i);
    }
  }
})(require('process'));

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
sequenceserver-3.1.3 public/vendor/npm/readable-stream@1.1.14/lib/_stream_duplex.js
sequenceserver-3.1.2 public/vendor/npm/readable-stream@1.1.14/lib/_stream_duplex.js
sequenceserver-3.1.1 public/vendor/npm/readable-stream@1.1.14/lib/_stream_duplex.js
sequenceserver-3.1.0 public/vendor/npm/readable-stream@1.1.14/lib/_stream_duplex.js
sequenceserver-3.0.1 public/vendor/npm/readable-stream@1.1.14/lib/_stream_duplex.js
sequenceserver-3.0 public/vendor/npm/readable-stream@1.1.14/lib/_stream_duplex.js
sequenceserver-2.2.0 public/vendor/npm/readable-stream@1.1.14/lib/_stream_duplex.js
sequenceserver-2.1.0 public/vendor/npm/readable-stream@1.1.14/lib/_stream_duplex.js