diff --git a/worker/worker.go b/worker/worker.go index 27f92a9..b8c1642 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -178,8 +178,8 @@ func (worker *Worker) Work() { go v.Work() } ok := true - var job *Job for ok { + var job *Job if job, ok = <-worker.in; ok { go func() { defer job.Close()