From d786bc328130a53613379617fa9b2f7b15b4f353 Mon Sep 17 00:00:00 2001 From: crusader Date: Fri, 27 Apr 2018 15:24:22 +0900 Subject: [PATCH] ing --- socket/net/client/connector.go | 3 +++ socket/web/client/connector.go | 3 +++ 2 files changed, 6 insertions(+) diff --git a/socket/net/client/connector.go b/socket/net/client/connector.go index d8b0b96..7d0fbfd 100644 --- a/socket/net/client/connector.go +++ b/socket/net/client/connector.go @@ -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 diff --git a/socket/web/client/connector.go b/socket/web/client/connector.go index 6739426..edadcf1 100644 --- a/socket/web/client/connector.go +++ b/socket/web/client/connector.go @@ -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