diff --git a/conn.go b/conn.go index af41beb..a42521d 100644 --- a/conn.go +++ b/conn.go @@ -687,6 +687,9 @@ func (c *Conn) NextReader() (messageType int, r io.Reader, err error) { for c.readErr == nil { frameType, err := c.advanceFrame() if err != nil { + if e, ok := err.(net.Error); ok && e.Timeout() { + continue + } c.readErr = hideTempErr(err) break }