deno.land / std@0.166.0 / node / internal / streams / destroy.mjs
نووسراو ببینە
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321// Copyright 2018-2022 the Deno authors. All rights reserved. MIT license.// Copyright Joyent and Node contributors. All rights reserved. MIT license.// deno-lint-ignore-file
import { aggregateTwoErrors, ERR_MULTIPLE_CALLBACK } from "../errors.ts";import * as process from "../../_process/process.ts";
const kDestroy = Symbol("kDestroy");const kConstruct = Symbol("kConstruct");
function checkError(err, w, r) { if (err) { // Avoid V8 leak, https://github.com/nodejs/node/pull/34103#issuecomment-652002364 err.stack; // eslint-disable-line no-unused-expressions
if (w && !w.errored) { w.errored = err; } if (r && !r.errored) { r.errored = err; } }}
// Backwards compat. cb() is undocumented and unused in core but// unfortunately might be used by modules.function destroy(err, cb) { const r = this._readableState; const w = this._writableState; // With duplex streams we use the writable side for state. const s = w || r;
if ((w && w.destroyed) || (r && r.destroyed)) { if (typeof cb === "function") { cb(); }
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 checkError(err, w, r);
if (w) { w.destroyed = true; } if (r) { r.destroyed = true; }
// If still constructing then defer calling _destroy. if (!s.constructed) { this.once(kDestroy, function (er) { _destroy(this, aggregateTwoErrors(er, err), cb); }); } else { _destroy(this, err, cb); }
return this;}
function _destroy(self, err, cb) { let called = false;
function onDestroy(err) { if (called) { return; } called = true;
const r = self._readableState; const w = self._writableState;
checkError(err, w, r);
if (w) { w.closed = true; } if (r) { r.closed = true; }
if (typeof cb === "function") { cb(err); }
if (err) { process.nextTick(emitErrorCloseNT, self, err); } else { process.nextTick(emitCloseNT, self); } } try { const result = self._destroy(err || null, onDestroy); if (result != null) { const then = result.then; if (typeof then === "function") { then.call( result, function () { process.nextTick(onDestroy, null); }, function (err) { process.nextTick(onDestroy, err); }, ); } } } catch (err) { onDestroy(err); }}
function emitErrorCloseNT(self, err) { emitErrorNT(self, err); emitCloseNT(self);}
function emitCloseNT(self) { const r = self._readableState; const w = self._writableState;
if (w) { w.closeEmitted = true; } if (r) { r.closeEmitted = true; }
if ((w && w.emitClose) || (r && r.emitClose)) { self.emit("close"); }}
function emitErrorNT(self, err) { const r = self._readableState; const w = self._writableState;
if ((w && w.errorEmitted) || (r && r.errorEmitted)) { return; }
if (w) { w.errorEmitted = true; } if (r) { r.errorEmitted = true; }
self.emit("error", err);}
function undestroy() { const r = this._readableState; const w = this._writableState;
if (r) { r.constructed = true; r.closed = false; r.closeEmitted = false; r.destroyed = false; r.errored = null; r.errorEmitted = false; r.reading = false; r.ended = false; r.endEmitted = false; }
if (w) { w.constructed = true; w.destroyed = false; w.closed = false; w.closeEmitted = false; w.errored = null; w.errorEmitted = false; w.ended = false; w.ending = false; w.finalCalled = false; w.prefinished = false; w.finished = false; }}
function errorOrDestroy(stream, err, sync) { // 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.
const r = stream._readableState; const w = stream._writableState;
if ((w && w.destroyed) || (r && r.destroyed)) { return this; }
if ((r && r.autoDestroy) || (w && w.autoDestroy)) { stream.destroy(err); } else if (err) { // Avoid V8 leak, https://github.com/nodejs/node/pull/34103#issuecomment-652002364 err.stack; // eslint-disable-line no-unused-expressions
if (w && !w.errored) { w.errored = err; } if (r && !r.errored) { r.errored = err; } if (sync) { process.nextTick(emitErrorNT, stream, err); } else { emitErrorNT(stream, err); } }}
function construct(stream, cb) { if (typeof stream._construct !== "function") { return; }
const r = stream._readableState; const w = stream._writableState;
if (r) { r.constructed = false; } if (w) { w.constructed = false; }
stream.once(kConstruct, cb);
if (stream.listenerCount(kConstruct) > 1) { // Duplex return; }
process.nextTick(constructNT, stream);}
function constructNT(stream) { let called = false;
function onConstruct(err) { if (called) { errorOrDestroy(stream, err ?? new ERR_MULTIPLE_CALLBACK()); return; } called = true;
const r = stream._readableState; const w = stream._writableState; const s = w || r;
if (r) { r.constructed = true; } if (w) { w.constructed = true; }
if (s.destroyed) { stream.emit(kDestroy, err); } else if (err) { errorOrDestroy(stream, err, true); } else { process.nextTick(emitConstructNT, stream); } }
try { const result = stream._construct(onConstruct); if (result != null) { const then = result.then; if (typeof then === "function") { then.call( result, function () { process.nextTick(onConstruct, null); }, function (err) { process.nextTick(onConstruct, err); }, ); } } } catch (err) { onConstruct(err); }}
function emitConstructNT(stream) { stream.emit(kConstruct);}
function isRequest(stream) { return stream && stream.setHeader && typeof stream.abort === "function";}
// Normalize destroy for legacy.function destroyer(stream, err) { if (!stream) return; if (isRequest(stream)) return stream.abort(); if (isRequest(stream.req)) return stream.req.abort(); if (typeof stream.destroy === "function") return stream.destroy(err); if (typeof stream.close === "function") return stream.close();}
export default { construct, destroyer, destroy, undestroy, errorOrDestroy,};export { construct, destroy, destroyer, errorOrDestroy, undestroy };
std
Version Info
a year ago
