diff --git a/main.go b/main.go index a750f8f5..0b5c9084 100644 --- a/main.go +++ b/main.go @@ -168,13 +168,13 @@ func streamEvents(w http.ResponseWriter, r *http.Request) { defer cancel() messages, _ := dockerClient.Events(ctx) +Loop: for { - exit := false select { case message, closed := <-messages: if closed { log.Println("Breaking from messages") - exit = true + break Loop } switch message.Action { case "connect": @@ -195,11 +195,7 @@ func streamEvents(w http.ResponseWriter, r *http.Request) { } case <-r.Context().Done(): cancel() - exit = true - } - - if exit { - break + break Loop } } }