diff --git a/transport/internet/websocket/wsconn.go b/transport/internet/websocket/wsconn.go index b9397ae23..b85df5719 100644 --- a/transport/internet/websocket/wsconn.go +++ b/transport/internet/websocket/wsconn.go @@ -29,6 +29,7 @@ func (c *wsconn) Read(b []byte) (int, error) { nBytes, err := reader.Read(b) if errors.Cause(err) == io.EOF { + c.reader = nil continue } return nBytes, err