@vingle/memcache-plus
Advanced tools
Comparing version 0.3.3 to 0.3.4
@@ -225,6 +225,12 @@ /** | ||
debug('flushing client write buffer'); | ||
// "Empty" buffer; | ||
let buffer = this.buffer; | ||
// Reset | ||
this.buffer = this.buffer.clear(); | ||
// @todo Watch out for and handle how this behaves with a very long buffer | ||
while(this.buffer.size > 0) { | ||
var item = this.buffer.first(); | ||
this.buffer = this.buffer.shift(); | ||
while(buffer.size > 0) { | ||
var item = buffer.first(); | ||
buffer = buffer.shift(); | ||
@@ -238,7 +244,3 @@ // Something bad happened before things got a chonce to run. We | ||
// First, retrieve the correct connection out of the hashring | ||
var connection = this.getConnection(item); | ||
var promise = connection[item.cmd].apply(connection, item.args); | ||
promise.then(item.deferred.resolve, item.deferred.reject); | ||
this.run(item.cmd, item.args).then(item.deferred.resolve, item.deferred.reject) | ||
} | ||
@@ -245,0 +247,0 @@ } |
{ | ||
"name": "@vingle/memcache-plus", | ||
"version": "0.3.3", | ||
"version": "0.3.4", | ||
"description": "Better memcache for node", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
2756
310241