We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 945eff5 commit f01d600Copy full SHA for f01d600
packages/microservices/client/client-redis.ts
@@ -26,7 +26,7 @@ export class ClientRedis extends ClientProxy {
26
protected pubClient: RedisClient;
27
protected subClient: RedisClient;
28
protected connection: Promise<any>;
29
- private readonly isExplicitlyTerminated = false;
+ protected isExplicitlyTerminated = false;
30
31
constructor(protected readonly options: ClientOptions['options']) {
32
super();
@@ -48,6 +48,7 @@ export class ClientRedis extends ClientProxy {
48
this.pubClient && this.pubClient.quit();
49
this.subClient && this.subClient.quit();
50
this.pubClient = this.subClient = null;
51
+ this.isExplicitlyTerminated = true;
52
}
53
54
public connect(): Promise<any> {
0 commit comments