diff --git a/main.go b/main.go index 90d91c57..0334b1e0 100644 --- a/main.go +++ b/main.go @@ -171,8 +171,8 @@ func streamEvents(w http.ResponseWriter, r *http.Request) { Loop: for { select { - case message, closed := <-messages: - if closed { + case message, ok := <-messages: + if !ok { break Loop } switch message.Action {