diff --git a/connection_impl.go b/connection_impl.go
index eb99f1c1..178ad0d4 100644
--- a/connection_impl.go
+++ b/connection_impl.go
@@ -410,9 +410,10 @@ func (c *connection) waitRead(n int) (err error) {
 			return Exception(ErrConnClosed, "wait read")
 		default:
 			err = <-c.readTrigger
-			if err != nil {
-				return err
-			}
+			//if err != nil {
+			//	return err
+			//}
+			continue
 		}
 	}
 	return nil
@@ -446,9 +447,9 @@ func (c *connection) waitReadWithTimeout(n int) (err error) {
 				}
 				return Exception(ErrReadTimeout, c.remoteAddr.String())
 			case err = <-c.readTrigger:
-				if err != nil {
-					return err
-				}
+				//if err != nil {
+				//	return err
+				//}
 				continue
 			}
 		}