Moving some logic that should fix the idle event

Signed-off-by: DTrejo <[email protected]>
sabermonk · Jul 6, 2012 · 2224767 · 2224767
1 parent b60e001
commit 2224767
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/index.js b/index.js
@@ -525,8 +525,9 @@ function reply_to_strings(reply) {
 
 RedisClient.prototype.return_reply = function (reply) {
     var command_obj, obj, i, len, type, timestamp, argindex, args, queue_len;
-
-    queue_len = this.command_queue.getLength();
+
+    command_obj = this.command_queue.shift()
+    queue_len   = this.command_queue.getLength();
 
     if (this.pub_sub_mode === false && queue_len === 0) {
         this.emit("idle");
@@ -537,8 +538,6 @@ RedisClient.prototype.return_reply = function (reply) {
         this.should_buffer = false;
     }
 
-    command_obj = this.command_queue.shift();
-
     if (command_obj && !command_obj.sub_command) {
         if (typeof command_obj.callback === "function") {
             if (this.options.detect_buffers && command_obj.buffer_args === false) {