node-nats-streaming-buffered-client - npm Package Compare versions

Comparing version 1.5.0 to 1.5.1

dist/node-nats-streaming-buffered-client.js

@@ -133,2 +133,4 @@ "use strict";
         _this.logger.log('[NATS-BUFFERED-CLIENT] Constructing...');
+        _this.logger.log('[NATS-BUFFERED-CLIENT] Buffer size', _this.bufferSize);
+        _this.logger.log('[NATS-BUFFERED-CLIENT] Batch size', _this.batchSize);
         // Initialize our ring buffer with the requested size
@@ -374,3 +376,3 @@ //
         if (this.stan) {
-            var batchItems = this.buffer.slice(0, this.bufferSize);
+            var batchItems = this.buffer.slice(0, this.batchSize);
             if (!batchItems.length) {
@@ -384,3 +386,3 @@ this.logger.log('[NATS-BUFFERED-CLIENT] Buffer is empty. Going to sleep');
                 //
-                this.buffer = this.buffer.slice(this.bufferSize);
+                this.buffer = this.buffer.slice(this.batchSize);
                 // Collect publish promises for the entire batch
@@ -409,3 +411,3 @@ //
                     .then(function () {
-                    _this.logger.log("[NATS-BUFFERED-CLIENT] Buffer utilitisation " + Math.round(_this.buffer.length * 100 / _this.bufferSize) + "%", _this.buffer.length);
+                    _this.logger.log("[NATS-BUFFERED-CLIENT] Buffer utilisation " + Math.round(_this.buffer.length * 100 / _this.bufferSize) + "%", _this.buffer.length);
                     // Next buffer item batch
@@ -412,0 +414,0 @@ //

package.json

 {
   "name": "node-nats-streaming-buffered-client",
-  "version": "1.5.0",
+  "version": "1.5.1",
   "description": "",
@@ -5,0 +5,0 @@ "keywords": [],

No alert changes

Improved metrics

Total package byte prevSize

43215

increased by0.71%

Lines of code

633

increased by0.32%

No dependency changes