diff options
Diffstat (limited to 'src/bun.js/builtins/js/ReadableStreamInternals.js')
| -rw-r--r-- | src/bun.js/builtins/js/ReadableStreamInternals.js | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/src/bun.js/builtins/js/ReadableStreamInternals.js b/src/bun.js/builtins/js/ReadableStreamInternals.js index 15042baa5..f317eeaec 100644 --- a/src/bun.js/builtins/js/ReadableStreamInternals.js +++ b/src/bun.js/builtins/js/ReadableStreamInternals.js @@ -304,14 +304,9 @@ function readableStreamPipeToWritableStream( pipeState.pendingWritePromise = @Promise.@resolve(); if (signal !== @undefined) { - const algorithm = () => { + const algorithm = (reason) => { if (pipeState.finalized) return; - const error = @makeDOMException( - "AbortError", - "abort pipeTo from signal" - ); - @pipeToShutdownWithAction( pipeState, () => { @@ -320,7 +315,7 @@ function readableStreamPipeToWritableStream( @getByIdDirectPrivate(pipeState.destination, "state") === "writable"; const promiseDestination = shouldAbortDestination - ? @writableStreamAbort(pipeState.destination, error) + ? @writableStreamAbort(pipeState.destination, reason) : @Promise.@resolve(); const shouldAbortSource = @@ -328,7 +323,7 @@ function readableStreamPipeToWritableStream( @getByIdDirectPrivate(pipeState.source, "state") === @streamReadable; const promiseSource = shouldAbortSource - ? @readableStreamCancel(pipeState.source, error) + ? @readableStreamCancel(pipeState.source, reason) : @Promise.@resolve(); let promiseCapability = @newPromiseCapability(@Promise); @@ -350,7 +345,7 @@ function readableStreamPipeToWritableStream( promiseSource.@then(handleResolvedPromise, handleRejectedPromise); return promiseCapability.@promise; }, - error + reason ); }; if (@whenSignalAborted(signal, algorithm)) |