fix test break

8 years ago · 0d68293ef8
parent cdb0b94046
commit 0d68293ef8
1 changed files with 1 additions and 0 deletions
--- 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