Fix one instance of not accessing recvBuf via the getter

3 years ago · 104117cafb
parent 4bc80af9a1
commit 104117cafb
1 changed files with 1 additions and 1 deletions
--- a/internal/multiplex/session.go
+++ b/internal/multiplex/session.go
@ -264,7 +264,7 @@ func (sesh *Session) closeSession(closeSwitchboard bool) error {
 		}
 		stream := streamI.(*Stream)
 		atomic.StoreUint32(&stream.closed, 1)
-		_ = stream.recvBuf.Close() // will not block
+		_ = stream.getRecvBuf().Close() // will not block
 		sesh.streams.Delete(key)
 		sesh.streamCountDecr()
 		return true