Merge pull request #130635 from zimnx/fix-websocket-read-error

Return correct error upon websocket message read failure
This commit is contained in:
Kubernetes Prow Robot
2025-03-07 08:45:53 -08:00
committed by GitHub

View File

@@ -312,7 +312,7 @@ func (c *wsStreamCreator) readDemuxLoop(bufferSize int, period time.Duration, de
if errRead == io.EOF { if errRead == io.EOF {
break break
} }
c.closeAllStreamReaders(fmt.Errorf("read message: %w", err)) c.closeAllStreamReaders(fmt.Errorf("read message: %w", errRead))
return return
} }
} }