Zy Filemanager

📁 File Browser

Name	Size	Permissions	Actions
📁 internal	DIR	0755	🗑️
📝 _stream_duplex.js (1,848 bytes)	1.8 KB	0644	✍️ ⬇️ 🗑️
📝 _stream_passthrough.js (604 bytes)	604 B	0644	✍️ ⬇️ 🗑️
📝 _stream_readable.js (28,102 bytes)	27.44 KB	0644	✍️ ⬇️ 🗑️
📝 _stream_transform.js (6,354 bytes)	6.21 KB	0644	✍️ ⬇️ 🗑️
📝 _stream_writable.js (15,062 bytes)	14.71 KB	0644	✍️ ⬇️ 🗑️

📤 Upload Files

Single File

Multiple Files

ZIP Extract

ZIP file will be deleted after extraction

➕ Create New

New Folder

New File

✍️ Editing: _stream_duplex.js

            File: /opt/alt/alt-nodejs6/root/usr/lib/node_modules/npm/node_modules.bundled/readable-stream/lib/_stream_duplex.js

            Size: 1.8 KB | 
            Last Modified: 2021-09-28 16:36:07        

// a duplex stream is just a stream that is both readable and writable.
// Since JS doesn't have multiple prototypal inheritance, this class
// prototypally inherits from Readable, and then parasitically from
// Writable.

'use strict';

/*<replacement>*/

var objectKeys = Object.keys || function (obj) {
  var keys = [];
  for (var key in obj) {
    keys.push(key);
  }return keys;
};
/*</replacement>*/

module.exports = Duplex;

/*<replacement>*/
var processNextTick = require('process-nextick-args');
/*</replacement>*/

/*<replacement>*/
var util = require('core-util-is');
util.inherits = require('inherits');
/*</replacement>*/

var Readable = require('./_stream_readable');
var Writable = require('./_stream_writable');

util.inherits(Duplex, Readable);

var keys = objectKeys(Writable.prototype);
for (var v = 0; v < keys.length; v++) {
  var method = keys[v];
  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);
}

// the no-half-open enforcer
function onend() {
  // if we allow half-open state, or if the writable side ended,
  // then we're ok.
  if (this.allowHalfOpen || this._writableState.ended) return;

// no more data can be written.
  // But allow more writes to happen in this tick.
  processNextTick(onEndNT, this);
}

function onEndNT(self) {
  self.end();
}

function forEach(xs, f) {
  for (var i = 0, l = xs.length; i < l; i++) {
    f(xs[i], i);
  }
}

↩️ Back