Merge pull request #168 from meteorrn/fix/event-emit

jankapunkt · web-flow · commit 7cd471259248 · 2025-08-25T09:28:54.000+02:00
possible fix for #167
diff --git a/lib/ddp.js b/lib/ddp.js
@@ -203,11 +203,12 @@ class DDP extends EventEmitter {
   }
 
   /**
-   * Emits a new event. Wraps emitting in a setTimeout (macrotask)
+   * Emits a new event.
    * @override
    */
-  emit() {
-    setTimeout(super.emit.bind(this, ...arguments), 0);
+  emit(...args) {
+    Promise.resolve().then(() => super.emit(...args));
+    return true;
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -203,11 +203,12 @@ class DDP extends EventEmitter {`
`203`	`203`	`}`
`204`	`204`
`205`	`205`	`/**`
`206`		`- * Emits a new event. Wraps emitting in a setTimeout (macrotask)`
	`206`	`+ * Emits a new event.`
`207`	`207`	`* @override`
`208`	`208`	`*/`
`209`		`- emit() {`
`210`		`- setTimeout(super.emit.bind(this, ...arguments), 0);`
	`209`	`+ emit(...args) {`
	`210`	`+ Promise.resolve().then(() => super.emit(...args));`
	`211`	`+ return true;`
`211`	`212`	`}`
`212`	`213`
`213`	`214`	`/**`