{“ast”:null,“code”:“'use strict';n/*<replacement>*/nnvar pna = require('process-nextick-args');n/*</replacement>*/n// undocumented cb() API, needed for core, not for public APInnnfunction destroy(err, cb) {n var _this = this;nn var readableDestroyed = this._readableState && this._readableState.destroyed;n var writableDestroyed = this._writableState && this._writableState.destroyed;nn if (readableDestroyed || writableDestroyed) {n if (cb) {n cb(err);n } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {n pna.nextTick(emitErrorNT, this, err);n }nn return this;n } // we set destroyed to true before firing error callbacks in ordern // to make it re-entrance safe in case destroy() is called within callbacksnnn if (this._readableState) {n this._readableState.destroyed = true;n } // if this is a duplex stream mark the writable part as destroyed as wellnnn if (this._writableState) {n this._writableState.destroyed = true;n }nn this._destroy(err || null, function (err) {n if (!cb && err) {n pna.nextTick(emitErrorNT, _this, err);nn if (_this._writableState) {n _this._writableState.errorEmitted = true;n }n } else if (cb) {n cb(err);n }n });nn return this;n}nnfunction undestroy() {n if (this._readableState) {n this._readableState.destroyed = false;n this._readableState.reading = false;n this._readableState.ended = false;n this._readableState.endEmitted = false;n }nn if (this._writableState) {n this._writableState.destroyed = false;n this._writableState.ended = false;n this._writableState.ending = false;n this._writableState.finished = false;n this._writableState.errorEmitted = false;n }n}nnfunction emitErrorNT(self, err) {n self.emit('error', err);n}nnmodule.exports = {n destroy: destroy,n undestroy: undestroyn};”,“map”:null,“metadata”:{},“sourceType”:“module”}