ing
This commit is contained in:
parent
3654ce7ec1
commit
d786bc3281
|
@ -88,6 +88,9 @@ func (c *Connectors) logHeader() string {
|
|||
}
|
||||
|
||||
func (c *Connectors) onDisconnected() {
|
||||
close(c.readChan)
|
||||
close(c.writeChan)
|
||||
|
||||
c.reconnectedChan <- nil
|
||||
|
||||
onDisconnected := c.OnDisconnected
|
||||
|
|
|
@ -125,6 +125,9 @@ func (c *Connectors) logHeader() string {
|
|||
}
|
||||
|
||||
func (c *Connectors) onDisconnected() {
|
||||
close(c.readChan)
|
||||
close(c.writeChan)
|
||||
|
||||
c.reconnectedChan <- nil
|
||||
|
||||
onDisconnected := c.OnDisconnected
|
||||
|
|
Loading…
Reference in New Issue
Block a user