diff --git a/pkg/util/wsstream/conn.go b/pkg/util/wsstream/conn.go index 0c1033cd859..719cf191a67 100644 --- a/pkg/util/wsstream/conn.go +++ b/pkg/util/wsstream/conn.go @@ -97,9 +97,7 @@ func ignoreReceives(ws *websocket.Conn, timeout time.Duration) { for { resetTimeout(ws, timeout) if err := websocket.Message.Receive(ws, &data); err != nil { - if err == io.EOF { - return - } + return } } }