Skip to content

Commit 81f8dd8

Browse files
When ending, ensure no retries happen
1 parent 252a77e commit 81f8dd8

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

index.js

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -826,6 +826,8 @@ RedisClient.prototype.end = function () {
826826
this.stream._events = {};
827827
this.connected = false;
828828
this.ready = false;
829+
this.closing = true;
830+
clearTimeout(this.retry_timer);
829831
return this.stream.end();
830832
};
831833

0 commit comments

Comments
 (0)