rm readTrigger error

cloudwego · Nov 28, 2023 · f5610b8 · f5610b8
1 parent 0a1eaea
commit f5610b8
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/connection_impl.go b/connection_impl.go
@@ -411,9 +411,10 @@ func (c *connection) waitRead(n int) (err error) {
 			return Exception(ErrConnClosed, "wait read")
 		default:
 			err = <-c.readTrigger
-			if err != nil {
-				return err
-			}
+			continue
+			//if err != nil {
+			//	return err
+			//}
 		}
 	}
 	return nil
@@ -447,9 +448,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
 			}
 		}