From 12c8241987b39bd73116477e7c7e75310afdddb8 Mon Sep 17 00:00:00 2001 From: zarazaex69 Date: Thu, 9 Apr 2026 16:54:44 +0300 Subject: [PATCH] fix(mux): Reset stream state when client ID changes --- internal/mux/mux.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/internal/mux/mux.go b/internal/mux/mux.go index 64f49df..8382371 100644 --- a/internal/mux/mux.go +++ b/internal/mux/mux.go @@ -141,10 +141,12 @@ func (m *Multiplexer) HandleFrame(frame []byte) { recvBuf: make([]byte, 0), } m.streams[sid] = stream + } else if stream.ClientID != clientID { + stream.ClientID = clientID + stream.recvBuf = make([]byte, 0) + stream.closed = false } - if stream.ClientID == clientID { - stream.recvBuf = append(stream.recvBuf, data...) - } + stream.recvBuf = append(stream.recvBuf, data...) m.mu.Unlock() }