stream: use cause options in AbortError constructors

Signed-off-by: James M Snell <jasnell@gmail.com> PR-URL: #41008 Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de> Reviewed-By: Robert Nagy <ronagy@icloud.com> Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
nodejs · Aug 1, 2022 · 046deba · 046deba
1 parent 2aae868
commit 046deba
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/lib/internal/streams/add-abort-signal.js b/lib/internal/streams/add-abort-signal.js
@@ -34,7 +34,7 @@ module.exports.addAbortSignalNoValidate = function(signal, stream) {
     return stream;
   }
   const onAbort = () => {
-    stream.destroy(new AbortError());
+    stream.destroy(new AbortError(undefined, { cause: signal.reason }));
   };
   if (signal.aborted) {
     onAbort();

diff --git a/lib/internal/streams/duplexify.js b/lib/internal/streams/duplexify.js
@@ -214,7 +214,8 @@ function fromAsyncGen(fn) {
       const { chunk, done, cb } = await _promise;
       process.nextTick(cb);
       if (done) return;
-      if (signal.aborted) throw new AbortError();
+      if (signal.aborted)
+        throw new AbortError(undefined, { cause: signal.reason });
       ({ promise, resolve } = createDeferredPromise());
       yield chunk;
     }

diff --git a/lib/internal/streams/end-of-stream.js b/lib/internal/streams/end-of-stream.js
@@ -220,7 +220,9 @@ function eos(stream, options, callback) {
       // Keep it because cleanup removes it.
       const endCallback = callback;
       cleanup();
-      endCallback.call(stream, new AbortError());
+      endCallback.call(
+        stream,
+        new AbortError(undefined, { cause: options.signal.reason }));
     };
     if (options.signal.aborted) {
       process.nextTick(abort);