Re-attempt to fix max stack call exceeded error

moscajs · Aug 26, 2019 · 01ca230 · 01ca230
1 parent 63ced23
commit 01ca230
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/client.js b/lib/client.js
@@ -94,7 +94,7 @@ function Client (broker, conn) {
         write(that, packet, cb)
       })
     } else {
-      cb()
+      setImmediate(cb)
     }
   }
 
@@ -125,9 +125,9 @@ function Client (broker, conn) {
       that.broker.persistence.outgoingClearMessageId(that, _packet, nop)
       // we consider this to be an error, since the packet is undefined
       // so there's nothing to send
-      cb()
+      setImmediate(cb)
     } else {
-      cb()
+      setImmediate(cb)
     }
   }