avoid write to close channel

Signed-off-by: Jakub Dyszkiewicz <[email protected]>
kumahq · Sep 26, 2024 · ef45646 · ef45646
1 parent 5a946e8
commit ef45646
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/server/sotw/v3/xds.go b/pkg/server/sotw/v3/xds.go
@@ -45,6 +45,10 @@ func (s *server) process(str stream.Stream, reqCh chan *discovery.DiscoveryReque
 	// s.ctx.Done()
 	sw.watches.recompute(s.ctx, reqCh)
 
+	if s.opts.Ordered {
+		return s.processADS(&sw, reqCh, defaultTypeURL)
+	}
+
 	for {
 		// The list of select cases looks like this:
 		// 0: <- ctx.Done