@supy-io/nestjs-jetstream - npm Package Compare versions

Comparing version 1.4.2 to 1.4.3

dist/server.js

@@ -42,14 +42,18 @@ "use strict";
             this.logger.log(`Subscribed to ${subject} events`);
-            for await (const msg of subscription) {
-                try {
-                    const stream$ = this.handleJetStreamEvent(msg, eventHandler);
-                    this.send(stream$, () => null);
+            const done = (async () => {
+                for await (const msg of subscription) {
+                    try {
+                        const stream$ = this.handleJetStreamEvent(msg, eventHandler);
+                        this.send(stream$, () => null);
+                    }
+                    catch (err) {
+                        this.logger.error(err.message, err.stack);
+                        msg.term();
+                    }
                 }
-                catch (err) {
-                    this.logger.error(err.message, err.stack);
-                    msg.term();
-                }
-            }
-            subscription.destroy();
-            this.logger.log(`Unsubscribed ${subject}`);
+            })();
+            done.then(() => {
+                subscription.destroy();
+                this.logger.log(`Unsubscribed ${subject}`);
+            });
         }
@@ -72,5 +76,3 @@ }
                     const stream$ = this.handleJetStreamMessage(msg, messageHandler);
-                    this.send(stream$, (response) => {
-                        msg.respond(this.codec.encode(response));
-                    });
+                    this.send(stream$, (response) => msg.respond(this.codec.encode(response)));
                 },
@@ -77,0 +79,0 @@ };

package.json

 {
   "name": "@supy-io/nestjs-jetstream",
-  "version": "1.4.2",
+  "version": "1.4.3",
   "description": "Nats JetStream Transport for NestJS",
@@ -53,3 +53,3 @@ "main": "dist/index.js",
   },
-  "gitHead": "3240dda9ef25b4d5b1ef2603339b59bb70cf80e8"
+  "gitHead": "e4f774af73b30c99e3a1d1cc5bd5e22042a98b76"
 }

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

151257

increased by0.14%

Lines of code

481

increased by0.42%

No dependency changes