revert

web/server.go

@@ -442,22 +442,20 @@ func (s *Server) handleEvents() http.HandlerFunc {
 		}()
 
 		// Keep connection open and send events as they arrive
-		go func() {
+		for {
-			for {
+			select {
-				select {
+			case msg, ok := <-clientChan:
-				case msg, ok := <-clientChan:
+				if !ok {
-					if !ok {
-						return
-					}
-					fmt.Fprintf(w, "%s\n\n", msg)
-					if flusher, ok := w.(http.Flusher); ok {
-						flusher.Flush()
-					}
-				case <-r.Context().Done():
 					return
 				}
+				fmt.Fprintf(w, "%s\n\n", msg)
+				if flusher, ok := w.(http.Flusher); ok {
+					flusher.Flush()
+				}
+			case <-r.Context().Done():
+				return
 			}
-		}()
+		}
 	}
 }
 
@@ -505,22 +503,20 @@ func (s *Server) handleAdminEvents() http.HandlerFunc {
 		}()
 
 		// Keep connection open and send events as they arrive
-		go func() {
+		for {
-			for {
+			select {
-				select {
+			case msg, ok := <-clientChan:
-				case msg, ok := <-clientChan:
+				if !ok {
-					if !ok {
-						return
-					}
-					fmt.Fprintf(w, "%s\n\n", msg)
-					if flusher, ok := w.(http.Flusher); ok {
-						flusher.Flush()
-					}
-				case <-r.Context().Done():
 					return
 				}
+				fmt.Fprintf(w, "%s\n\n", msg)
+				if flusher, ok := w.(http.Flusher); ok {
+					flusher.Flush()
+				}
+			case <-r.Context().Done():
+				return
 			}
-		}()
+		}
 	}
 }