cmd/mi: fix reddit errors

2020-01-12 04:19:15 +00:00 · 2020-01-12 04:19:15 +00:00 · 27a8595cbc
parent 7a928aaa4a
commit 27a8595cbc
1 changed files with 4 additions and 2 deletions
--- a/cmd/mi/reddit.go
+++ b/cmd/mi/reddit.go
@ -71,8 +71,10 @@ func (mi *Mi) StreamReddit(ctx context.Context) {
 			kill <- true
 			kill <- true
 			runtime.Goexit()
-		case <-errs:
-			ln.Error(ctx, err)
+		case err := <-errs:
+			if err != nil {
+				ln.Error(ctx, err)
+			}
 		case p := <-posts:
 			ln.Log(ctx, ln.Info("got reddit post"), ln.F{
 				"from": p.Author,