diff --git a/req.go b/req.go index 3945e8b..55be5f6 100644 --- a/req.go +++ b/req.go @@ -367,16 +367,18 @@ func performReq( readevents: for { select { - case ie, ok := <-results: - if !ok { + case ie, stillOpen := <-results: + if !stillOpen { break readevents } stdout(ie.Event) - case closed := <-closeds: - if closed.HandledAuth { - logverbose("%s CLOSED: %s\n", closed.Relay.URL, closed.Reason) - } else { - log("%s CLOSED: %s\n", closed.Relay.URL, closed.Reason) + case closed, stillOpen := <-closeds: + if stillOpen { + if closed.HandledAuth { + logverbose("%s CLOSED: %s\n", closed.Relay.URL, closed.Reason) + } else { + log("%s CLOSED: %s\n", closed.Relay.URL, closed.Reason) + } } case <-ctx.Done(): break readevents