keuss - npm Package Compare versions

Comparing version 1.5.5 to 1.5.6

package.json

 {
   "name": "keuss",
-  "version": "1.5.5",
+  "version": "1.5.6",
   "keywords": [
@@ -5,0 +5,0 @@ "queue",

Queue.js

@@ -93,2 +93,3 @@ var async = require ('async');
   topology (cb) {this._stats.topology (cb);}
+  paused   (cb) {this._stats.paused (cb);}
 
@@ -312,3 +313,3 @@ // placeholder methods
       debug ('%s: pop while drained, return error', this._name);
-      callback ('drain');
+      if (callback) callback ('drain');
     });
@@ -363,5 +364,7 @@
 
-      this._stats.paused (v => {
+      this._stats.paused ((err, v) => {
         this._local_paused = v;
 
+        debug ('%s: local_paused undefined, read paused status from stats:', this._name, v);
+
         if (!this._local_paused) {
@@ -494,12 +497,11 @@ // attempt a read
   //////////////////////////////////
-    var self = this;
-
     async.parallel ({
-      type:          function (cb) {cb (null, self.type())},
-      stats:         function (cb) {self.stats (cb)},
-      topology:      function (cb) {self.topology (cb)},
-      next_mature_t: function (cb) {self.next_t (cb)},
-      size:          function (cb) {self.size (cb)},
-      totalSize:     function (cb) {self.totalSize (cb)},
-      schedSize:     function (cb) {self.schedSize (cb)}
+      type:          cb => cb (null, this.type()),
+      stats:         cb => this.stats (cb),
+      topology:      cb => this.topology (cb),
+      paused:        cb => this.paused (cb),
+      next_mature_t: cb => this.next_t (cb),
+      size:          cb => this.size (cb),
+      totalSize:     cb => this.totalSize (cb),
+      schedSize:     cb => this.schedSize (cb)
     }, cb);
@@ -506,0 +508,0 @@ }

README.md

@@ -293,13 +293,9 @@ # keuss
 // pauses the queue
-q.pause (true, function (err){
-  ...
-})
+q.pause (true)
 
 // resumes the queue
-q.pause (false, function (err){
-  ...
-})
+q.pause (false)
 
 // gets paused status of queue
-q.pause (function (err, is_paused){
+q.paused (function (err, is_paused){
   ...
@@ -306,0 +302,0 @@ })

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

1390513

Lines of code

7165

increased by0.03%

Worsened metrics

Number of lines in readme file

490

decreased by-0.81%

No dependency changes