From 95de7f517652b457eed60b836c57e8765240851c Mon Sep 17 00:00:00 2001 From: Paulo Almeida Date: Sat, 25 Jan 2025 09:08:55 +0000 Subject: [PATCH] fix: proxy start endeless loop --- internal/proxymanager/proxy.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/internal/proxymanager/proxy.go b/internal/proxymanager/proxy.go index cd76056..18474a3 100644 --- a/internal/proxymanager/proxy.go +++ b/internal/proxymanager/proxy.go @@ -172,10 +172,12 @@ func (proxy *Proxy) Start() { go func() { go proxy.start() for { - event := <-proxy.providerProxy.WatchEvents() - proxy.state.Store(int32(event.State)) - - // TODO + select { + case event := <-proxy.providerProxy.WatchEvents(): + proxy.state.Store(int32(event.State)) + case <-proxy.ctx.Done(): + return + } } }() }