tq: un-defer close()
call for clarity
This commit is contained in:
parent
1852300266
commit
d7bf608380
@ -106,13 +106,12 @@ func (a *adapterBase) Add(transfers ...*Transfer) <-chan TransferResult {
|
|||||||
a.jobWait.Add(len(transfers))
|
a.jobWait.Add(len(transfers))
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
defer close(results)
|
|
||||||
|
|
||||||
for _, t := range transfers {
|
for _, t := range transfers {
|
||||||
a.jobChan <- &job{t, results, a.jobWait}
|
a.jobChan <- &job{t, results, a.jobWait}
|
||||||
}
|
}
|
||||||
|
|
||||||
a.jobWait.Wait()
|
a.jobWait.Wait()
|
||||||
|
|
||||||
|
close(results)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
return results
|
return results
|
||||||
|
Loading…
Reference in New Issue
Block a user