From 104117cafbbd01bd01fe5bd11a4fa1fcd06f9567 Mon Sep 17 00:00:00 2001 From: Andy Wang Date: Tue, 22 Dec 2020 14:32:41 +0000 Subject: [PATCH] Fix one instance of not accessing recvBuf via the getter --- internal/multiplex/session.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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