globalcache
Advanced tools
Comparing version 2.7.0 to 2.8.0
14
index.js
@@ -139,9 +139,13 @@ var util = require('util'), | ||
socket.destroy(); | ||
self.emit('error', err); | ||
for (var key in callbacks) | ||
callbacks[key](err); | ||
//self.emit('error', err); | ||
}); | ||
socket.on('timeout', function () { | ||
socket.on('timeout', function (err) { | ||
console.error('node-itach :: error :: ', 'Timeout'); | ||
socket.destroy(); | ||
self.emit('error', 'Timeout'); | ||
for (var key in callbacks) | ||
callbacks[key](err); | ||
//self.emit('error', err); | ||
}); | ||
@@ -194,5 +198,5 @@ | ||
this.socket.end(); | ||
debugger; | ||
messageQueue.clear(); | ||
callbacks.clear(); | ||
callbacks = {}; | ||
} | ||
@@ -199,0 +203,0 @@ this.send = function (input, done) { |
@@ -43,3 +43,3 @@ { | ||
}, | ||
"version": "2.7.0" | ||
"version": "2.8.0" | ||
} |
19000
301