diff --git a/adapter/pkg/discovery/protocol/server/sotw/v3/server.go b/adapter/pkg/discovery/protocol/server/sotw/v3/server.go index a764b18ec..aedf6b101 100644 --- a/adapter/pkg/discovery/protocol/server/sotw/v3/server.go +++ b/adapter/pkg/discovery/protocol/server/sotw/v3/server.go @@ -231,6 +231,7 @@ func (s *server) process(stream streamv3.Stream, reqCh <-chan *discovery.Discove } } + for { select { case <-s.ctx.Done():