Skip to content

Commit b5eb9ff

Browse files
committed
fix lint
1 parent c14a7c4 commit b5eb9ff

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

modules/queue/workergroup.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -210,9 +210,9 @@ func (q *WorkerPoolQueue[T]) doFlush(wg *workerGroup[T], flush flushType) {
210210
wg.batchBuffer = nil
211211
for {
212212
select {
213-
case _ = <-wg.popItemChan:
214-
case _ = <-wg.popItemErr:
215-
case _ = <-q.batchChan:
213+
case <-wg.popItemChan:
214+
case <-wg.popItemErr:
215+
case <-q.batchChan:
216216
case <-q.ctxRun.Done():
217217
return
218218
default:

0 commit comments

Comments
 (0)