30 lines
710 B
Go
30 lines
710 B
Go
|
package chain
|
||
|
|
|
||
|
|
import "golang.org/x/sync/errgroup"
|
||
|
|
|
||
|
|
// RunSequentially runs the given functions sequentially,
|
||
|
|
// If any function returns an error, it stops the execution and returns that error.
|
||
|
|
// If all functions return nil, it returns nil.
|
||
|
|
func RunSequentially(fs ...func() error) error {
|
||
|
|
for _, f := range fs {
|
||
|
|
if err := f(); err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// RunParallel runs the given functions in parallel,
|
||
|
|
// It waits for all functions to finish and returns the first error encountered.
|
||
|
|
func RunParallel(fs ...func() error) func() error {
|
||
|
|
return func() error {
|
||
|
|
g := errgroup.Group{}
|
||
|
|
for _, f := range fs {
|
||
|
|
g.Go(func() error {
|
||
|
|
return f()
|
||
|
|
})
|
||
|
|
}
|
||
|
|
return g.Wait()
|
||
|
|
}
|
||
|
|
}
|