From 66ea93e3c144563c0b7c51368336f43f505eaf05 Mon Sep 17 00:00:00 2001 From: xfy Date: Wed, 10 Jun 2026 13:48:07 +0800 Subject: [PATCH] fix(stream): reset stopCh after Stop for restartability --- internal/stream/stream.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/stream/stream.go b/internal/stream/stream.go index ae77e7a..56402a3 100644 --- a/internal/stream/stream.go +++ b/internal/stream/stream.go @@ -550,6 +550,7 @@ func (s *Server) Stop() { s.mu.Lock() s.listeners = make(map[string]net.Listener) s.udpServers = make(map[string]*udpServer) + s.stopCh = make(chan struct{}) s.mu.Unlock() }