Explorar o código

change logic for stopper chan in stream helm rel function

Alexander Belanger %!s(int64=5) %!d(string=hai) anos
pai
achega
fadb9f731a
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      internal/kubernetes/agent.go

+ 1 - 1
internal/kubernetes/agent.go

@@ -819,7 +819,7 @@ func (a *Agent) StreamHelmReleases(conn *websocket.Conn, chartList []string, sel
 		for {
 			if _, _, err := conn.ReadMessage(); err != nil {
 				defer conn.Close()
-				defer close(stopper)
+				close(stopper)
 				errorchan <- nil
 				return
 			}