nats - npm Package Compare versions

Comparing version 2.15.0 to 2.15.1

lib/jetstream/consumer.d.ts

 import { Timeout } from "../nats-base-client/util";
 import { ConsumerAPI, ConsumerAPIImpl } from "./jsmconsumer_api";
 import { QueuedIteratorImpl } from "../nats-base-client/queued_iterator";
-import { MsgHdrs, QueuedIterator, Subscription } from "../nats-base-client/core";
+import { MsgHdrs, QueuedIterator, Status, Subscription } from "../nats-base-client/core";
 import * as core from "../nats-base-client/idleheartbeat";
@@ -165,2 +165,3 @@ import { JsMsg } from "./jsmsg";
     listeners: QueuedIterator<ConsumerStatus>[];
+    statusIterator?: QueuedIteratorImpl<Status>;
     constructor(c: PullConsumerImpl, opts: ConsumeOptions | FetchOptions, refilling?: boolean);
@@ -212,2 +213,3 @@ _push(r: JsMsg): void;
     inactive_threshold: number;
+    headers_only: boolean;
 };
@@ -214,0 +216,0 @@ export declare class OrderedPullConsumerImpl implements Consumer {

lib/jetstream/consumer.js

@@ -242,5 +242,7 @@ "use strict";
             var _d;
+            const status = c.api.nc.status();
+            this.statusIterator = status;
             try {
-                for (var _e = true, _f = __asyncValues(c.api.nc.status()), _g; _g = yield _f.next(), _a = _g.done, !_a;) {
-                    _c = _g.value;
+                for (var _e = true, status_1 = __asyncValues(status), status_1_1; status_1_1 = yield status_1.next(), _a = status_1_1.done, !_a;) {
+                    _c = status_1_1.value;
                     _e = false;
@@ -282,3 +284,3 @@ try {
                 try {
-                    if (!_e && !_a && (_b = _f.return)) yield _b.call(_f);
+                    if (!_e && !_a && (_b = status_1.return)) yield _b.call(status_1);
                 }
@@ -396,5 +398,6 @@ finally { if (e_1) throw e_1.error; }
     stop(err) {
-        var _a;
+        var _a, _b;
         (_a = this.sub) === null || _a === void 0 ? void 0 : _a.unsubscribe();
         this.clearTimers();
+        (_b = this.statusIterator) === null || _b === void 0 ? void 0 : _b.stop();
         //@ts-ignore: fn
@@ -631,2 +634,5 @@ this._push(() => {
         };
+        if (this.consumerOpts.headers_only === true) {
+            config.headers_only = true;
+        }
         if (Array.isArray(this.consumerOpts.filterSubjects)) {
@@ -633,0 +639,0 @@ config.filter_subjects = this.consumerOpts.filterSubjects;

lib/nats-base-client/nats.js

@@ -398,2 +398,6 @@ "use strict";
         const iter = new queued_iterator_1.QueuedIteratorImpl();
+        iter.iterClosed.then(() => {
+            const idx = this.listeners.indexOf(iter);
+            this.listeners.splice(idx, 1);
+        });
         this.listeners.push(iter);
@@ -400,0 +404,0 @@ return iter;

lib/src/node_transport.js

@@ -46,3 +46,3 @@ "use strict";
 const dns = require("dns");
-const VERSION = "2.15.0";
+const VERSION = "2.15.1";
 const LANG = "nats.js";
@@ -49,0 +49,0 @@ class NodeTransport {

package.json

 {
   "name": "nats",
-  "version": "2.15.0",
+  "version": "2.15.1",
   "description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system",
@@ -45,3 +45,3 @@ "keywords": [
     "clean": "shx rm -Rf ./lib/* ./nats-base-client ./.deps",
-    "clone-nbc": "shx mkdir -p ./.deps && cd ./.deps && git clone --branch v1.15.0 https://github.com/nats-io/nats.deno.git",
+    "clone-nbc": "shx mkdir -p ./.deps && cd ./.deps && git clone --branch v1.15.1 https://github.com/nats-io/nats.deno.git",
     "fmt": "deno fmt ./src/ ./examples/ ./test/",
@@ -48,0 +48,0 @@ "prepack": "npm run clone-nbc && npm run cjs && npm run check-package && npm run build",

No alert changes

Improved metrics

Total package byte prevSize

1066011

increased by0.09%

Lines of code

18320

increased by0.07%

No dependency changes