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