feat: implement All with Paralleler.

Author: ghosind

all.go

@@ -50,61 +50,12 @@ func AllWithContext(ctx context.Context, funcs ...AsyncFn) ([][]any, error) {
 // all executes the functions asynchronously until all functions have been finished, or the context
 // is done (canceled or timeout).
 func all(parent context.Context, funcs ...AsyncFn) ([][]any, error) {
-	if len(funcs) == 0 {
-		return nil, nil
-	}
-	validateAsyncFuncs(funcs...)
-
-	parent = getContext(parent)
-
-	ctx, canFunc := context.WithCancel(parent)
-	defer canFunc()
-
-	ch := make(chan executeResult, len(funcs))
-	defer close(ch)
-
-	for i := 0; i < len(funcs); i++ {
-		go runTaskInAll(ctx, i, funcs[i], ch)
-	}
-
-	finished := 0
-	out := make([][]any, len(funcs))
-	for finished < len(funcs) {
-		select {
-		case <-parent.Done():
-			return out, ErrContextCanceled
-		case ret := <-ch:
-			out[ret.Index] = ret.Out
-			if ret.Error != nil {
-				return out, &executionError{
-					index: ret.Index,
-					err:   ret.Error,
-				}
-			}
-			finished++
-		}
-	}
+	paralleler := new(Paralleler).
+		WithContext(parent)
 
-	return out, nil
-}
+	paralleler.Add(funcs...)
 
-// runTaskInAll runs the specified function for All / AllWithContext.
-func runTaskInAll(ctx context.Context, n int, fn AsyncFn, ch chan<- executeResult) {
-	childCtx, childCanFunc := context.WithCancel(ctx)
-	defer childCanFunc()
-
-	ret, err := invokeAsyncFn(fn, childCtx, nil)
-
-	select {
-	case <-ctx.Done():
-		return
-	default:
-		ch <- executeResult{
-			Error: err,
-			Index: n,
-			Out:   ret,
-		}
-	}
+	return paralleler.Run()
 }
 
 // AllCompleted executes the functions asynchronously until all functions have been finished. It

all_test.go

@@ -16,7 +16,7 @@ func TestAllWithoutFuncs(t *testing.T) {
 
 	out, err := async.All()
 	a.NilNow(err)
-	a.NilNow(out)
+	a.EqualNow(out, [][]any{})
 }
 
 func TestAllSuccess(t *testing.T) {