Rem: session.SetRQLen

client_test.go

@@ -87,7 +87,6 @@ func newSessionCallback(session Session, handler *MessageHandler) error {
 	session.SetMaxMsgLen(1024)
 	session.SetPkgHandler(&pkgHandler)
 	session.SetEventListener(handler)
-	session.SetRQLen(4)
 	session.SetWQLen(32)
 	session.SetReadTimeout(3e9)
 	session.SetWriteTimeout(3e9)

demo/hello/tcp/config.go

@@ -63,7 +63,6 @@ func InitialSession(session getty.Session) (err error) {
 
 	session.SetName("hello")
 	session.SetMaxMsgLen(128)
-	// session.SetRQLen(1024)
 	session.SetWQLen(512)
 	session.SetReadTimeout(time.Second)
 	session.SetWriteTimeout(5 * time.Second)

demo/hello/tls/config.go

@@ -43,7 +43,6 @@ func InitialSession(session getty.Session) (err error) {
 	if ok {
 		session.SetName("hello")
 		session.SetMaxMsgLen(128)
-		// session.SetRQLen(1024)
 		session.SetWQLen(512)
 		session.SetReadTimeout(time.Second)
 		session.SetWriteTimeout(5 * time.Second)

getty.go

@@ -163,9 +163,6 @@ type Session interface {
 	SetWriter(Writer)
 	SetCronPeriod(int)
 
-	// Deprecated: don't use read queue.
-	SetRQLen(int)
-
 	SetWQLen(int)
 	SetWaitTime(time.Duration)
 	// Deprecated: don't use SetTaskPool, move to endpoints layer.

go.mod

@@ -3,7 +3,7 @@ module github.com/apache/dubbo-getty
 go 1.14
 
 require (
-	github.com/dubbogo/gost v1.9.6
+	github.com/dubbogo/gost v1.9.7
 	github.com/golang/snappy v0.0.1
 	github.com/gorilla/websocket v1.4.2
 	github.com/pkg/errors v0.9.1

session.go

@@ -299,9 +299,6 @@ func (s *session) SetCronPeriod(period int) {
 	s.period = time.Duration(period) * time.Millisecond
 }
 
-// Deprecated: don't use read queue.
-func (s *session) SetRQLen(readQLen int) {}
-
 // set @session's Write queue size
 func (s *session) SetWQLen(writeQLen int) {
 	if writeQLen < 1 {