From 4bf62f6cbdb4ad02524e88e05b30d5ced9e3f0d6 Mon Sep 17 00:00:00 2001 From: Benjamin Gruenbaum Date: Fri, 12 Jul 2024 21:00:27 +0300 Subject: [PATCH] stream: improve inspector ergonomics PR-URL: https://github.com/nodejs/node/pull/53800 Fixes: https://github.com/nodejs/node/issues/53789 Reviewed-By: James M Snell Reviewed-By: Yagiz Nizipli Reviewed-By: Marco Ippolito --- lib/internal/webstreams/readablestream.js | 4 ++-- lib/internal/webstreams/writablestream.js | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/internal/webstreams/readablestream.js b/lib/internal/webstreams/readablestream.js index c1bf9909ee1449..f37f5174918c6d 100644 --- a/lib/internal/webstreams/readablestream.js +++ b/lib/internal/webstreams/readablestream.js @@ -2041,8 +2041,8 @@ function readableStreamError(stream, error) { assert(stream[kState].state === 'readable'); stream[kState].state = 'errored'; stream[kState].storedError = error; - stream[kIsClosedPromise].reject(error); setPromiseHandled(stream[kIsClosedPromise].promise); + stream[kIsClosedPromise].reject(error); const { reader, @@ -2051,8 +2051,8 @@ function readableStreamError(stream, error) { if (reader === undefined) return; - reader[kState].close.reject(error); setPromiseHandled(reader[kState].close.promise); + reader[kState].close.reject(error); if (readableStreamHasDefaultReader(stream)) { for (let n = 0; n < reader[kState].readRequests.length; n++) diff --git a/lib/internal/webstreams/writablestream.js b/lib/internal/webstreams/writablestream.js index 9842f852247f67..43f7a5121b1e97 100644 --- a/lib/internal/webstreams/writablestream.js +++ b/lib/internal/webstreams/writablestream.js @@ -768,15 +768,15 @@ function writableStreamRejectCloseAndClosedPromiseIfNeeded(stream) { }; } - stream[kIsClosedPromise].reject(stream[kState]?.storedError); setPromiseHandled(stream[kIsClosedPromise].promise); + stream[kIsClosedPromise].reject(stream[kState]?.storedError); const { writer, } = stream[kState]; if (writer !== undefined) { - writer[kState].close.reject?.(stream[kState].storedError); setPromiseHandled(writer[kState].close.promise); + writer[kState].close.reject?.(stream[kState].storedError); } }