From 33de8a4f070adf76ad9ab0dd07094436996d2d28 Mon Sep 17 00:00:00 2001 From: Amir Raminfar Date: Tue, 27 Nov 2018 11:22:13 -0800 Subject: [PATCH] Uses labels instead --- main.go | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) 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 } } }