diff --git a/lib/internal/webstreams/transformstream.js b/lib/internal/webstreams/transformstream.js index 516a6ac0116862..3dc85b79a8273e 100644 --- a/lib/internal/webstreams/transformstream.js +++ b/lib/internal/webstreams/transformstream.js @@ -579,7 +579,7 @@ async function transformStreamDefaultSinkAbortAlgorithm(stream, reason) { } = stream[kState]; if (controller[kState].finishPromise !== undefined) { - return controller[kState].finishPromise + return controller[kState].finishPromise; } const { promise, resolve, reject } = createDeferredPromise(); @@ -603,7 +603,7 @@ async function transformStreamDefaultSinkAbortAlgorithm(stream, reason) { (error) => { readableStreamDefaultControllerError(readable[kState].controller, error); reject(error); - } + }, ); return controller[kState].finishPromise; @@ -616,7 +616,7 @@ function transformStreamDefaultSinkCloseAlgorithm(stream) { } = stream[kState]; if (controller[kState].finishPromise !== undefined) { - return controller[kState].finishPromise + return controller[kState].finishPromise; } const { promise, resolve, reject } = createDeferredPromise(); controller[kState].finishPromise = promise; @@ -669,27 +669,27 @@ function transformStreamDefaultSourceCancelAlgorithm(stream, reason) { transformStreamDefaultControllerClearAlgorithms(controller); PromisePrototypeThen(cancelPromise, - () => { - if (writable[kState].state === 'errored') - reject(writable[kState].storedError); - else { - writableStreamDefaultControllerErrorIfNeeded( - writable[kState].controller, - reason); - transformStreamUnblockWrite(stream); - resolve(); - } - }, - (error) => { - writableStreamDefaultControllerErrorIfNeeded( - writable[kState].controller, - error); - transformStreamUnblockWrite(stream); - reject(error); - } + () => { + if (writable[kState].state === 'errored') + reject(writable[kState].storedError); + else { + writableStreamDefaultControllerErrorIfNeeded( + writable[kState].controller, + reason); + transformStreamUnblockWrite(stream); + resolve(); + } + }, + (error) => { + writableStreamDefaultControllerErrorIfNeeded( + writable[kState].controller, + error); + transformStreamUnblockWrite(stream); + reject(error); + }, ); - return controller[kState].finishPromise + return controller[kState].finishPromise; } module.exports = {