Anton Kaliaev
8 years ago
No known key found for this signature in database
GPG Key ID: 7B6881D965918214
2 changed files with
5 additions and
1 deletions
-
client/ws_client.go
-
server/handlers.go
|
|
|
@ -85,6 +85,8 @@ func (wsc *WSClient) dial() error { |
|
|
|
|
|
|
|
func (wsc *WSClient) OnStop() { |
|
|
|
wsc.BaseService.OnStop() |
|
|
|
wsc.Conn.Close() |
|
|
|
wsc.Conn = nil |
|
|
|
// ResultsCh/ErrorsCh is closed in receiveEventsRoutine.
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -373,7 +373,9 @@ func (wsc *wsConnection) OnStart() error { |
|
|
|
|
|
|
|
func (wsc *wsConnection) OnStop() { |
|
|
|
wsc.BaseService.OnStop() |
|
|
|
wsc.evsw.RemoveListener(wsc.remoteAddr) |
|
|
|
if wsc.evsw != nil { |
|
|
|
wsc.evsw.RemoveListener(wsc.remoteAddr) |
|
|
|
} |
|
|
|
wsc.readTimeout.Stop() |
|
|
|
wsc.pingTicker.Stop() |
|
|
|
// The write loop closes the websocket connection
|
|
|
|
|
