[fix] connection: not working set ModWriteChanSize

2 years ago · fb71d367b4
parent 104b0f77f8
commit fb71d367b4
1 changed files with 1 additions and 1 deletions
--- a/pkg/connection/connection.go
+++ b/pkg/connection/connection.go
@ -230,7 +230,7 @@ func (c *connection) ModWriteChanSize(n int) {
 	if c.option.WriteChanSize > 0 {
 		panic(ErrConnectionPanic)
 	}
-	if c.option.WriteChanSize == 0 {
+	if n == 0 {
 		return
 	}