File Explorer

/var/runtime/node_modules/@aws-sdk/node_modules/readable-stream/lib/internal/streams

This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.

0 dirs
4 files

destroy.js2.1 KB · 84 lines

1'use strict';2 3/*<replacement>*/4 5var pna = require('process-nextick-args');6/*</replacement>*/7 8// undocumented cb() API, needed for core, not for public API9function destroy(err, cb) {10  var _this = this;11 12  var readableDestroyed = this._readableState && this._readableState.destroyed;13  var writableDestroyed = this._writableState && this._writableState.destroyed;14 15  if (readableDestroyed || writableDestroyed) {16    if (cb) {17      cb(err);18    } else if (err) {19      if (!this._writableState) {20        pna.nextTick(emitErrorNT, this, err);21      } else if (!this._writableState.errorEmitted) {22        this._writableState.errorEmitted = true;23        pna.nextTick(emitErrorNT, this, err);24      }25    }26 27    return this;28  }29 30  // we set destroyed to true before firing error callbacks in order31  // to make it re-entrance safe in case destroy() is called within callbacks32 33  if (this._readableState) {34    this._readableState.destroyed = true;35  }36 37  // if this is a duplex stream mark the writable part as destroyed as well38  if (this._writableState) {39    this._writableState.destroyed = true;40  }41 42  this._destroy(err || null, function (err) {43    if (!cb && err) {44      if (!_this._writableState) {45        pna.nextTick(emitErrorNT, _this, err);46      } else if (!_this._writableState.errorEmitted) {47        _this._writableState.errorEmitted = true;48        pna.nextTick(emitErrorNT, _this, err);49      }50    } else if (cb) {51      cb(err);52    }53  });54 55  return this;56}57 58function undestroy() {59  if (this._readableState) {60    this._readableState.destroyed = false;61    this._readableState.reading = false;62    this._readableState.ended = false;63    this._readableState.endEmitted = false;64  }65 66  if (this._writableState) {67    this._writableState.destroyed = false;68    this._writableState.ended = false;69    this._writableState.ending = false;70    this._writableState.finalCalled = false;71    this._writableState.prefinished = false;72    this._writableState.finished = false;73    this._writableState.errorEmitted = false;74  }75}76 77function emitErrorNT(self, err) {78  self.emit('error', err);79}80 81module.exports = {82  destroy: destroy,83  undestroy: undestroy84};