fix(ext/web/streams): enqueue to second branch before closing (denola…

…nd#16269)

Co-authored-by: Luca Casonato <hello@lcas.dev>

ext/web/06_streams.js

@@ -2616,6 +2616,7 @@
     assert(typeof cloneForBranch2 === "boolean");
     const reader = acquireReadableStreamDefaultReader(stream);
     let reading = false;
+    let readAgain = false;
     let canceled1 = false;
     let canceled2 = false;
     /** @type {any} */
@@ -2634,14 +2635,15 @@
 
     function pullAlgorithm() {
       if (reading === true) {
+        readAgain = true;
         return resolvePromiseWith(undefined);
       }
       reading = true;
       /** @type {ReadRequest<R>} */
       const readRequest = {
         chunkSteps(value) {
           queueMicrotask(() => {
-            reading = false;
+            readAgain = false;
             const value1 = value;
             const value2 = value;
 
@@ -2663,6 +2665,11 @@
                 value2,
               );
             }
+
+            reading = false;
+            if (readAgain === true) {
+              pullAlgorithm();
+            }
           });
         },
         closeSteps() {

tools/wpt/expectation.json

@@ -1336,12 +1336,8 @@
       "patched-global.any.worker.html": true,
       "reentrant-strategies.any.html": true,
       "reentrant-strategies.any.worker.html": true,
-      "tee.any.html": [
-        "ReadableStream teeing: enqueue() and close() while both branches are pulling"
-      ],
-      "tee.any.worker.html": [
-        "ReadableStream teeing: enqueue() and close() while both branches are pulling"
-      ],
+      "tee.any.html": true,
+      "tee.any.worker.html": true,
       "templated.any.html": true,
       "templated.any.worker.html": true
     },