quic: Fix wake up blob

Author: martenrichter

lib/internal/blob.js

@@ -475,9 +475,15 @@ function createBlobReaderStream(reader) {
       this.pendingPulls = [];
       // Register a wakeup callback that the C++ side can invoke
       // when new data is available after a STATUS_BLOCK.
+      let immediate;
       reader.setWakeup(() => {
-        if (this.pendingPulls.length > 0) {
-          this.readNext(c);
+        if (this.pendingPulls.length > 0 &&
+          typeof immediate === 'undefined') {
+          // Postpone the execution to the next steps of the event loop
+          immediate = setImmediate(() => {
+            immediate = undefined;
+            this.readNext(c);
+          });
         }
       });
     },
@@ -564,7 +570,16 @@ const kMaxBatchChunks = 16;
 async function* createBlobReaderIterable(reader, options = kEmptyObject) {
   const { getReadError } = options;
   let wakeup = PromiseWithResolvers();
-  reader.setWakeup(wakeup.resolve);
+  let immediate;
+  reader.setWakeup(() => {
+    if (typeof immediate === 'undefined') {
+      // Postpone the execution to the next steps of the event loop
+      immediate = setImmediate(() => {
+        immediate = undefined;
+        wakeup.resolve?.();
+      });
+    }
+  });
 
   try {
     while (true) {
@@ -611,7 +626,6 @@ async function* createBlobReaderIterable(reader, options = kEmptyObject) {
       if (blocked) {
         const fin = await wakeup.promise;
         wakeup = PromiseWithResolvers();
-        reader.setWakeup(wakeup.resolve);
         // If the wakeup was triggered by FIN (EndReadable), the DataQueue
         // is capped. Continue the loop to pull again -- the next pull will
         // return EOS. Without this, a race between the data notification