linting

nodejs · Dec 5, 2023 · 2557e85 · 2557e85
1 parent 23e6183
commit 2557e85
Showing 1 changed file with 22 additions and 22 deletions.
diff --git 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 = {