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: destroy.js

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

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

'use strict'; // undocumented cb() API, needed for core, not for public API

function destroy(err, cb) {
  var _this = this;

var readableDestroyed = this._readableState && this._readableState.destroyed;
  var writableDestroyed = this._writableState && this._writableState.destroyed;

if (readableDestroyed || writableDestroyed) {
    if (cb) {
      cb(err);
    } else if (err) {
      if (!this._writableState) {
        process.nextTick(emitErrorNT, this, err);
      } else if (!this._writableState.errorEmitted) {
        this._writableState.errorEmitted = true;
        process.nextTick(emitErrorNT, this, err);
      }
    }

return this;
  } // we set destroyed to true before firing error callbacks in order
  // to make it re-entrance safe in case destroy() is called within callbacks

if (this._readableState) {
    this._readableState.destroyed = true;
  } // if this is a duplex stream mark the writable part as destroyed as well

if (this._writableState) {
    this._writableState.destroyed = true;
  }

this._destroy(err || null, function (err) {
    if (!cb && err) {
      if (!_this._writableState) {
        process.nextTick(emitErrorAndCloseNT, _this, err);
      } else if (!_this._writableState.errorEmitted) {
        _this._writableState.errorEmitted = true;
        process.nextTick(emitErrorAndCloseNT, _this, err);
      } else {
        process.nextTick(emitCloseNT, _this);
      }
    } else if (cb) {
      process.nextTick(emitCloseNT, _this);
      cb(err);
    } else {
      process.nextTick(emitCloseNT, _this);
    }
  });

return this;
}

function emitErrorAndCloseNT(self, err) {
  emitErrorNT(self, err);
  emitCloseNT(self);
}

function emitCloseNT(self) {
  if (self._writableState && !self._writableState.emitClose) return;
  if (self._readableState && !self._readableState.emitClose) return;
  self.emit('close');
}

function undestroy() {
  if (this._readableState) {
    this._readableState.destroyed = false;
    this._readableState.reading = false;
    this._readableState.ended = false;
    this._readableState.endEmitted = false;
  }

if (this._writableState) {
    this._writableState.destroyed = false;
    this._writableState.ended = false;
    this._writableState.ending = false;
    this._writableState.finalCalled = false;
    this._writableState.prefinished = false;
    this._writableState.finished = false;
    this._writableState.errorEmitted = false;
  }
}

function emitErrorNT(self, err) {
  self.emit('error', err);
}

function errorOrDestroy(stream, err) {
  // We have tests that rely on errors being emitted
  // in the same tick, so changing this is semver major.
  // For now when you opt-in to autoDestroy we allow
  // the error to be emitted nextTick. In a future
  // semver major update we should change the default to this.
  var rState = stream._readableState;
  var wState = stream._writableState;
  if (rState && rState.autoDestroy || wState && wState.autoDestroy) stream.destroy(err);else stream.emit('error', err);
}

module.exports = {
  destroy: destroy,
  undestroy: undestroy,
  errorOrDestroy: errorOrDestroy
};

↩️ Back