diff --git a/lib/internal/streams/destroy.js b/lib/internal/streams/destroy.js index 2f543f2d36bace..20863a324f565f 100644 --- a/lib/internal/streams/destroy.js +++ b/lib/internal/streams/destroy.js @@ -35,7 +35,7 @@ function destroy(err, cb) { // With duplex streams we use the writable side for state. const s = w || r; - if ((w && w.destroyed) || (r && r.destroyed)) { + if (w?.destroyed || r?.destroyed) { if (typeof cb === 'function') { cb(); } @@ -134,7 +134,7 @@ function emitCloseNT(self) { r.closeEmitted = true; } - if ((w && w.emitClose) || (r && r.emitClose)) { + if (w?.emitClose || r?.emitClose) { self.emit('close'); } } @@ -143,7 +143,7 @@ function emitErrorNT(self, err) { const r = self._readableState; const w = self._writableState; - if ((w && w.errorEmitted) || (r && r.errorEmitted)) { + if (w?.errorEmitted || r?.errorEmitted) { return; } @@ -198,11 +198,11 @@ function errorOrDestroy(stream, err, sync) { const r = stream._readableState; const w = stream._writableState; - if ((w && w.destroyed) || (r && r.destroyed)) { + if (w?.destroyed || r?.destroyed) { return this; } - if ((r && r.autoDestroy) || (w && w.autoDestroy)) + if (r?.autoDestroy || w?.autoDestroy) stream.destroy(err); else if (err) { // Avoid V8 leak, https://github.com/nodejs/node/pull/34103#issuecomment-652002364 @@ -306,7 +306,7 @@ function emitConstructNT(stream) { } function isRequest(stream) { - return stream && stream.setHeader && typeof stream.abort === 'function'; + return stream?.setHeader && typeof stream.abort === 'function'; } // Normalize destroy for legacy.