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

Return correct error upon websocket message read failure

Kubernetes-commit: 0e2a2afc4c7687e71f2dddbb7edfd03f082c6876
This commit is contained in:
Kubernetes Publisher 2025-03-07 08:45:53 -08:00
commit 0445543f66

View File

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