fix: prefer queueMicrotask (#2881)

nodejs · Feb 28, 2024 · ed89b45 · ed89b45
1 parent c90af4a
commit ed89b45
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/lib/core/util.js b/lib/core/util.js
@@ -204,9 +204,9 @@ function destroy (stream, err) {
 
     stream.destroy(err)
   } else if (err) {
-    process.nextTick((stream, err) => {
+    queueMicrotask(() => {
       stream.emit('error', err)
-    }, stream, err)
+    })
   }
 
   if (stream.destroyed !== true) {

diff --git a/lib/dispatcher/client.js b/lib/dispatcher/client.js
@@ -299,7 +299,7 @@ class Client extends DispatcherBase {
     } else if (util.bodyLength(request.body) == null && util.isIterable(request.body)) {
       // Wait a tick in case stream/iterator is ended in the same tick.
       this[kResuming] = 1
-      process.nextTick(resume, this)
+      queueMicrotask(() => resume(this))
     } else {
       this[kResume](true)
     }
@@ -548,7 +548,7 @@ function _resume (client, sync) {
     } else if (client[kNeedDrain] === 2) {
       if (sync) {
         client[kNeedDrain] = 1
-        process.nextTick(emitDrain, client)
+        queueMicrotask(() => emitDrain(client))
       } else {
         emitDrain(client)
       }

diff --git a/lib/dispatcher/pool-base.js b/lib/dispatcher/pool-base.js
@@ -158,7 +158,7 @@ class PoolBase extends DispatcherBase {
     this[kClients].push(client)
 
     if (this[kNeedDrain]) {
-      process.nextTick(() => {
+      queueMicrotask(() => {
         if (this[kNeedDrain]) {
           this[kOnDrain](client[kUrl], [this, client])
         }