zmq-pool - npm Package Compare versions

Comparing version 0.1.0 to 0.1.1

lib/ZmqPool.js

@@ -104,5 +104,5 @@ var zmq = require('zmq');
 
-ZmqPool.prototype._onDone = function (uri, connectionId) {
+ZmqPool.prototype._onDone = function (uri, connectionId, options) {
   var self = this;
-  if (self.concurrency[uri] > self.minimumConcurrent) {
+  if (options.kill || self.concurrency[uri] > self.minimumConcurrent) {
     self.connections[connectionId].close();
@@ -109,0 +109,0 @@ delete self.connections[connectionId];

lib/ZmqSocket.js

@@ -57,3 +57,4 @@ var _ = require('lodash');
   var prototype = {
-    done: function () {
+    done: function (options) {
+      options = options || {};
       var self = this;
@@ -69,3 +70,3 @@ _.each(self._callbacks, function (listeners, event) {
       });
-      self.emit('done', self.uri, self.id);
+      self.emit('done', self.uri, self.id, options);
     }
@@ -72,0 +73,0 @@ };

package.json

 {
   "name": "zmq-pool",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Build a connection pool on top of ZMQ",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

12565

increased by0.58%

Lines of code

258

increased by0.39%

No dependency changes