From d7bf6083804d1a3dca04a76813a36f73ea2ecaba Mon Sep 17 00:00:00 2001 From: Taylor Blau Date: Mon, 12 Dec 2016 15:37:02 -0700 Subject: [PATCH] tq: un-defer `close()` call for clarity --- tq/adapterbase.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/tq/adapterbase.go b/tq/adapterbase.go index 5e1f93d4..6b842bc2 100644 --- a/tq/adapterbase.go +++ b/tq/adapterbase.go @@ -106,13 +106,12 @@ func (a *adapterBase) Add(transfers ...*Transfer) <-chan TransferResult { a.jobWait.Add(len(transfers)) go func() { - defer close(results) - for _, t := range transfers { a.jobChan <- &job{t, results, a.jobWait} } - a.jobWait.Wait() + + close(results) }() return results