@dxos/async - npm Package Compare versions

Comparing version 2.16.12 to 2.16.13

dist/src/event.js

@@ -64,6 +64,6 @@ "use strict";
         for (const listener of this._listeners) {
-            this._trigger(listener, data);
+            void this._trigger(listener, data);
         }
         for (const listener of this._onceListeners) {
-            this._trigger(listener, data);
+            void this._trigger(listener, data);
             this._onceListeners.delete(listener);
@@ -219,6 +219,5 @@ }
     }
-    _trigger(listener, data) {
-        setImmediate(() => {
-            listener(data);
-        });
+    async _trigger(listener, data) {
+        await waitImmediate(); // Acts like setImmediate but preserves the stack-trace.
+        listener(data);
     }
@@ -240,2 +239,6 @@ _runEffects() {
 exports.Event = Event;
+/**
+ * Like setImmediate but for async/await API. Useful for preserving stack-traces.
+ */
+const waitImmediate = () => new Promise((resolve) => setImmediate(resolve));
 //# sourceMappingURL=event.js.map

package.json

 {
 	"name": "@dxos/async",
-	"version": "2.16.12",
+	"version": "2.16.13",
 	"description": "Async utils.",
@@ -27,3 +27,3 @@ "bugs": {
 	"dependencies": {
-		"@dxos/debug": "2.16.12"
+		"@dxos/debug": "2.16.13"
 	},
@@ -30,0 +30,0 @@ "devDependencies": {

src/event.ts

@@ -81,7 +81,7 @@ //
     for (const listener of this._listeners) {
-      this._trigger(listener, data);
+      void this._trigger(listener, data);
     }
 
     for (const listener of this._onceListeners) {
-      this._trigger(listener, data);
+      void this._trigger(listener, data);
       this._onceListeners.delete(listener);
@@ -258,6 +258,5 @@ }
 
-  private _trigger (listener: (data: T) => void, data: T) {
-    setImmediate(() => {
-      listener(data);
-    });
+  private async _trigger (listener: (data: T) => void, data: T) {
+    await waitImmediate(); // Acts like setImmediate but preserves the stack-trace.
+    listener(data);
   }
@@ -341,1 +340,6 @@
 }
+
+/**
+ * Like setImmediate but for async/await API. Useful for preserving stack-traces.
+ */
+const waitImmediate = () => new Promise((resolve) => setImmediate(resolve));

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

118959

increased by0.49%

Lines of code

2113

increased by0.28%

Dependency changes

• + Added@dxos/debug@2.16.13(transitive)

• - Removed@dxos/debug@2.16.12(transitive)

• Updated@dxos/debug@2.16.13