diff --git a/worker/agent.go b/worker/agent.go index a8ff6d2..c997878 100644 --- a/worker/agent.go +++ b/worker/agent.go @@ -36,8 +36,9 @@ func newAgent(addr string, worker *Worker) (a *agent, err error) { // outputing loop func (a *agent) outLoop() { ok := true + var job *Job for ok { - if job, ok := <-a.out; ok { + if job, ok = <-a.out; ok { if err := a.write(job.Encode()); err != nil { a.worker.err(err) }