You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-07 13:22:56 +03:00
prototype.end move on("error", to outsite
This commit is contained in:
4
index.js
4
index.js
@@ -909,12 +909,12 @@ RedisClient.prototype.pub_sub_command = function (command_obj) {
|
|||||||
RedisClient.prototype.end = function () {
|
RedisClient.prototype.end = function () {
|
||||||
this.stream._events = {};
|
this.stream._events = {};
|
||||||
|
|
||||||
|
//clear retry_timer
|
||||||
if(this.retry_timer){
|
if(this.retry_timer){
|
||||||
clearTimeout(this.retry_timer);
|
clearTimeout(this.retry_timer);
|
||||||
this.retry_timer=null;
|
this.retry_timer=null;
|
||||||
this.stream.on("error", function(){
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
this.stream.on("error", function(){});
|
||||||
|
|
||||||
this.connected = false;
|
this.connected = false;
|
||||||
this.ready = false;
|
this.ready = false;
|
||||||
|
Reference in New Issue
Block a user