Skip to content

Commit 0ba3015

Browse files
committed
Resolved
1 parent 9ea28e4 commit 0ba3015

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/queue/httphandler/ticker.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -112,8 +112,8 @@ FOR_LOOP:
112112
select {
113113
case <-r.Context().Done():
114114
break FOR_LOOP
115-
case ticker := <-ch:
116-
if ticker == nil {
115+
case ticker, ok := <-ch:
116+
if !ok {
117117
break FOR_LOOP
118118
}
119119
textStream.Write("ticker", ticker)

0 commit comments

Comments
 (0)