Skip to content

Commit f58104a

Browse files
committed
fix: simply exit on errors
1 parent 430f784 commit f58104a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

proxy/websocket_pump.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -165,13 +165,13 @@ func (p *websocketPump) pumpMessages(
165165
default:
166166
if err := from.SetReadDeadline(utils.Deadline(timeout)); err != nil {
167167
notifyOnFailure(err)
168-
continue
168+
return
169169
}
170170

171171
msgType, bytes, err := from.ReadMessage()
172172
if err != nil {
173173
notifyOnFailure(err)
174-
continue
174+
return
175175
}
176176

177177
messages <- &websocketMessage{

0 commit comments

Comments
 (0)