fix: add s.incReadPkgNum()

5e89d5c2 · fangyincheng · f025e3f3 · 5e89d5c2
Commit 5e89d5c2 authored Jul 21, 2019 by fangyincheng
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

session.go session.go +1 -0

No files found.
--- a/session.go
+++ b/session.go
@@ -576,6 +576,7 @@ func (s *session) addTask(pkg interface{}) {
 	if s.tPool != nil {
 		s.tPool.AddTask(func() {
 			s.listener.OnMessage(s, pkg)
+			s.incReadPkgNum()
 		})
 	} else {
 		s.rQ <- pkg