streams: use nextTick on close

nodejs · Nov 21, 2021 · c4f0058 · c4f0058
1 parent 5c5608e
commit c4f0058
Showing 1 changed file with 28 additions and 24 deletions.
diff --git a/lib/internal/webstreams/readablestream.js b/lib/internal/webstreams/readablestream.js
@@ -1403,32 +1403,36 @@ function readableStreamTee(stream, cloneForBranch2) {
     reading = true;
     const readRequest = {
       [kChunk](value) {
-        reading = false;
-        const value1 = value;
-        let value2 = value;
-        if (!canceled2 && cloneForBranch2) {
-          // Structured Clone
-          value2 = deserialize(serialize(value2));
-        }
-        if (!canceled1) {
-          readableStreamDefaultControllerEnqueue(
-            branch1[kState].controller,
-            value1);
-        }
-        if (!canceled2) {
-          readableStreamDefaultControllerEnqueue(
-            branch2[kState].controller,
-            value2);
-        }
+        queueMicrotask(() => {
+          reading = false;
+          const value1 = value;
+          let value2 = value;
+          if (!canceled2 && cloneForBranch2) {
+            // Structured Clone
+            value2 = deserialize(serialize(value2));
+          }
+          if (!canceled1) {
+            readableStreamDefaultControllerEnqueue(
+              branch1[kState].controller,
+              value1);
+          }
+          if (!canceled2) {
+            readableStreamDefaultControllerEnqueue(
+              branch2[kState].controller,
+              value2);
+          }
+        });
       },
       [kClose]() {
-        reading = false;
-        if (!canceled1)
-          readableStreamDefaultControllerClose(branch1[kState].controller);
-        if (!canceled2)
-          readableStreamDefaultControllerClose(branch2[kState].controller);
-        if (!canceled1 || !canceled2)
-          cancelPromise.resolve();
+        process.nextTick(() => {
+          reading = false;
+          if (!canceled1)
+            readableStreamDefaultControllerClose(branch1[kState].controller);
+          if (!canceled2)
+            readableStreamDefaultControllerClose(branch2[kState].controller);
+          if (!canceled1 || !canceled2)
+            cancelPromise.resolve();
+        })
       },
       [kError]() {
         reading = false;