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()
 }