diff --git a/parallel.go b/parallel.go index 80e3a2f..1bfb445 100644 --- a/parallel.go +++ b/parallel.go @@ -65,6 +65,8 @@ func (l *List) RunParallel(callbacks ...Done) { } ) + defer close(result) + l.Wait.Add(l.Len()) go func() { @@ -104,8 +106,6 @@ func (l *List) RunParallel(callbacks ...Done) { l.Wait.Wait() - close(result) - if _error == nil { final(nil, results...) }