Nodejs/node
1
0
Fork 0
mirror of https://github.com/nodejs/node.git synced 2024-11-21 10:59:27 +00:00
Code Issues Actions 25 Packages Projects Releases Wiki Activity

stream: refactor use es2020 statement

Browse Source 
PR-URL: https://github.com/nodejs/node/pull/44533
Reviewed-By: Robert Nagy <ronagy@icloud.com>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Erick Wendel <erick.workspace@gmail.com>
This commit is contained in:
SindreXie 2022-09-06 15:58:31 +08:00 committed by Node.js GitHub Bot
parent b1f5a27aea
commit efad04910b
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/internal/streams/destroy.js
View File

@ -42,7 +42,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();
}
@ -128,7 +128,7 @@ function emitCloseNT(self) {
r.closeEmitted = true;
}
if ((w && w.emitClose) || (r && r.emitClose)) {
if (w?.emitClose || r?.emitClose) {
self.emit('close');
}
}
@ -137,7 +137,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;
}
@ -192,11 +192,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
@ -283,7 +283,7 @@ function emitConstructNT(stream) {
}
function isRequest(stream) {
return stream && stream.setHeader && typeof stream.abort === 'function';
return stream?.setHeader && typeof stream.abort === 'function';
}
function emitCloseLegacy(stream) {