globalcache - npm Package Compare versions

Comparing version 2.10.2 to 2.10.3

index.js

@@ -37,3 +37,3 @@ var util = require('util'),
 
-const DELAY_BETWEEN_COMMANDS = 500;
+const DELAY_BETWEEN_COMMANDS = 100;
 
@@ -105,7 +105,6 @@ function iTach(config) {
         }
-        send_();
+        sendFromQueue_();
     }
 
-    function send_() {
-
+    function sendFromQueue_(){
         if (!messageQueue.length) {
@@ -117,4 +116,9 @@ debug && console.log('Message queue is empty. returning...')
         debug && console.log('Taking next message from the queue.')
-        var message = messageQueue.shift(),
-            id = message[0],
+        var message = messageQueue.shift();
+        send_(message);
+    }
+
+    function send_(message) {
+
+        var id = message[0],
             data = message[1];
@@ -197,3 +201,3 @@
     	if (messageQueue.length){
-    		send_();
+    		sendFromQueue_();
     	}
@@ -208,4 +212,8 @@ }
     }
-    this.send = function (input, done) {
+    this.send = function (input, now, done) {
         if (!input) throw new Error('Missing input');
+        if (now && (messageQueue.length || isSending)){
+            debug && console.log("queue is not empty");
+            return;
+        }
 
@@ -253,7 +261,9 @@ var data, ir;
 
-        // add to queue
-        messageQueue.push([id, data]);
-
-        if (!isSending) {
-            send_();
+        if (now && !isSending)
+            send_([id, data]);
+        else {
+            // add to queue
+            messageQueue.push([id, data]);
+            if (!isSending)
+                sendFromQueue_();
         }
@@ -264,2 +274,2 @@ }
 util.inherits(iTach, EventEmitter);
-module.exports = {iTach: iTach};
+module.exports = {iTach: iTach};

package.json

@@ -43,3 +43,3 @@ {
   },
-  "version": "2.10.2"
+  "version": "2.10.3"
 }

No alert changes

Improved metrics

Total package byte prevSize

16497

increased by2.14%

Lines of code

240

increased by4.8%

No dependency changes