diff --git a/ext/web/06_streams.js b/ext/web/06_streams.js
index 361e5e0556..c783b95183 100644
--- a/ext/web/06_streams.js
+++ b/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,6 +2635,7 @@
 
     function pullAlgorithm() {
       if (reading === true) {
+        readAgain = true;
         return resolvePromiseWith(undefined);
       }
       reading = true;
@@ -2641,7 +2643,7 @@
       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() {
diff --git a/tools/wpt/expectation.json b/tools/wpt/expectation.json
index 558ada79aa..ed43da7e50 100644
--- a/tools/wpt/expectation.json
+++ b/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
     },