fix(cluster): stop subscriber when disconnecting

luin · luin · commit fb27b6609849 · 2018-10-15T02:38:58.000+08:00
diff --git a/lib/cluster/index.ts b/lib/cluster/index.ts
@@ -253,6 +253,8 @@ class Cluster extends EventEmitter {
       this.slotsTimer = null
     }
 
+    this.subscriber.stop()
+
     const Promise = PromiseContainer.get()
     if (status === 'wait') {
       const ret = asCallback(Promise.resolve('OK'), callback)

Original file line number	Diff line number	Diff line change
`@@ -253,6 +253,8 @@ class Cluster extends EventEmitter {`
`253`	`253`	`this.slotsTimer = null`
`254`	`254`	`}`
`255`	`255`
	`256`	`+ this.subscriber.stop()`
	`257`	`+`
`256`	`258`	`const Promise = PromiseContainer.get()`
`257`	`259`	`if (status === 'wait') {`
`258`	`260`	`const ret = asCallback(Promise.resolve('OK'), callback)`