You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-06 02:15:48 +03:00
ensure client emits connect and end events
This commit is contained in:
2
index.js
2
index.js
@@ -390,7 +390,7 @@ RedisClient.prototype.connection_gone = function () {
|
||||
console.warn("Redis connection is gone.");
|
||||
}
|
||||
self.connected = false;
|
||||
self.emit("close");
|
||||
self.emit("end");
|
||||
self.command_queue.forEach(function (args) {
|
||||
if (typeof args[2] === "function") {
|
||||
args[2]("Server connection closed");
|
||||
|
12
test.js
12
test.js
@@ -374,11 +374,18 @@ function run_next_test() {
|
||||
}
|
||||
}
|
||||
|
||||
var connected = false;
|
||||
var ended = false;
|
||||
client.on("connect", function () {
|
||||
connected = true;
|
||||
console.log();
|
||||
run_next_test();
|
||||
});
|
||||
|
||||
client.on('end', function() {
|
||||
ended = true;
|
||||
});
|
||||
|
||||
client.on("error", function (err) {
|
||||
console.log("Redis clent connection failed.");
|
||||
});
|
||||
@@ -390,3 +397,8 @@ client.on("reconnecting", function (msg) {
|
||||
process.on('uncaughtException', function (err) {
|
||||
console.log("Uncaught exception: " + err.stack);
|
||||
});
|
||||
|
||||
process.on('exit', function(code) {
|
||||
assert.equal(true, connected);
|
||||
assert.equal(true, ended);
|
||||
});
|
Reference in New Issue
Block a user