diff --git a/lib/memcached.js b/lib/memcached.js index 15b26e6..4112a1f 100644 --- a/lib/memcached.js +++ b/lib/memcached.js @@ -159,6 +159,11 @@ Client.config = { , streamError = function(e) { memcached.connectionIssue(e.toString(), S); Manager.remove(this); + var metaData = S.metaData.shift(); + if (metaData && metaData.callback){ + metaData.execution = Date.now() - metaData.start; + memcached.delegateCallback(metaData, e, false, metaData.callback); + } }; // config the Stream