Zy Filemanager

📁 File Browser

Name	Size	Permissions	Actions
📝 async_iterator.js (5,957 bytes)	5.82 KB	0644	✍️ ⬇️ 🗑️
📝 buffer_list.js (6,335 bytes)	6.19 KB	0644	✍️ ⬇️ 🗑️
📝 destroy.js (3,117 bytes)	3.04 KB	0644	✍️ ⬇️ 🗑️
📝 end-of-stream.js (3,102 bytes)	3.03 KB	0644	✍️ ⬇️ 🗑️
📝 from-browser.js (101 bytes)	101 B	0644	✍️ ⬇️ 🗑️
📝 from.js (3,137 bytes)	3.06 KB	0644	✍️ ⬇️ 🗑️
📝 pipeline.js (2,428 bytes)	2.37 KB	0644	✍️ ⬇️ 🗑️
📝 state.js (749 bytes)	749 B	0644	✍️ ⬇️ 🗑️
📝 stream-browser.js (49 bytes)	49 B	0644	✍️ ⬇️ 🗑️
📝 stream.js (36 bytes)	36 B	0644	✍️ ⬇️ 🗑️

📤 Upload Files

Single File

Multiple Files

ZIP Extract

ZIP file will be deleted after extraction

➕ Create New

New Folder

New File

✍️ Editing: pipeline.js

            File: /usr/lib/node_modules/npm/node_modules/readable-stream/lib/internal/streams/pipeline.js

            Size: 2.37 KB | 
            Last Modified: 2021-03-10 21:36:39        

// Ported from https://github.com/mafintosh/pump with
// permission from the author, Mathias Buus (@mafintosh).
'use strict';

var eos;

function once(callback) {
  var called = false;
  return function () {
    if (called) return;
    called = true;
    callback.apply(void 0, arguments);
  };
}

var _require$codes = require('../../../errors').codes,
    ERR_MISSING_ARGS = _require$codes.ERR_MISSING_ARGS,
    ERR_STREAM_DESTROYED = _require$codes.ERR_STREAM_DESTROYED;

function noop(err) {
  // Rethrow the error if it exists to avoid swallowing it
  if (err) throw err;
}

function isRequest(stream) {
  return stream.setHeader && typeof stream.abort === 'function';
}

if (isRequest(stream)) return stream.abort();
    if (typeof stream.destroy === 'function') return stream.destroy();
    callback(err || new ERR_STREAM_DESTROYED('pipe'));
  };
}

function call(fn) {
  fn();
}

function pipe(from, to) {
  return from.pipe(to);
}

function popCallback(streams) {
  if (!streams.length) return noop;
  if (typeof streams[streams.length - 1] !== 'function') return noop;
  return streams.pop();
}

function pipeline() {
  for (var _len = arguments.length, streams = new Array(_len), _key = 0; _key < _len; _key++) {
    streams[_key] = arguments[_key];
  }

var callback = popCallback(streams);
  if (Array.isArray(streams[0])) streams = streams[0];

if (streams.length < 2) {
    throw new ERR_MISSING_ARGS('streams');
  }

var error;
  var destroys = streams.map(function (stream, i) {
    var reading = i < streams.length - 1;
    var writing = i > 0;
    return destroyer(stream, reading, writing, function (err) {
      if (!error) error = err;
      if (err) destroys.forEach(call);
      if (reading) return;
      destroys.forEach(call);
      callback(error);
    });
  });
  return streams.reduce(pipe);
}

module.exports = pipeline;

↩️ Back