diff --git a/internal/multiplex/session.go b/internal/multiplex/session.go
index 1a4b8b4..9964f74 100644
--- 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