Skip to content

Commit aa8b3fe

Browse files
committed
fixed crash if closed from client
fixed #6
1 parent 7c9bc0a commit aa8b3fe

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

index.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,8 @@ Adapter.prototype.connect = function(cb) {
7070
}
7171

7272
Adapter.prototype.end = function(cb) {
73-
this.pubClient.end();
74-
this.subClient.end();
73+
this.redisPubClient.end();
74+
this.redisSubClient.end();
7575
}
7676

7777
/**

0 commit comments

Comments
 (0)