Skip to content

Commit e748f82

Browse files
committed
Fixed goroutine exit
1 parent 96a6b3f commit e748f82

File tree

1 file changed

+2
-2
lines changed
  • internal/events/websocket/mock_server

1 file changed

+2
-2
lines changed

internal/events/websocket/mock_server/server.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,7 @@ func (ws *WebSocketServer) WsPageHandler(w http.ResponseWriter, r *http.Request)
175175
case <-client.keepAliveLoopChan:
176176
client.keepAliveTimer.Stop()
177177
client.keepAliveLoopChan = nil
178-
break
178+
return
179179

180180
case <-client.keepAliveTimer.C: // Send KeepAlive message
181181
keepAliveMsg, _ := json.Marshal(
@@ -207,7 +207,7 @@ func (ws *WebSocketServer) WsPageHandler(w http.ResponseWriter, r *http.Request)
207207
case <-client.pingLoopChan:
208208
client.pingTimer.Stop()
209209
client.pingLoopChan = nil
210-
break
210+
return
211211

212212
case <-client.pingTimer.C: // Send ping
213213
err := client.SendMessage(websocket.PingMessage, []byte{})

0 commit comments

Comments
 (0)