bug fix

2014-07-21 10:10:56 +08:00 · 2014-07-21 10:10:56 +08:00 · 7850399753
parent b0eaa89a8e
commit 7850399753
1 changed files with 1 additions and 1 deletions
--- a/conn.go
+++ b/conn.go
@ -688,7 +688,7 @@ func (c *Conn) NextReader() (messageType int, r io.Reader, err error) {
 		frameType, err := c.advanceFrame()
 		if err != nil {
 			if e, ok := err.(net.Error); ok && e.Timeout() {
-				continue
+				return noFrame, nil, e
 			}
 			c.readErr = hideTempErr(err)
 			break