parallel

package

v0.17.0 Latest Latest Go to latest Published: Jan 18, 2022 License: MIT Imports: 3 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type WaitGroup struct {
	// contains filtered or unexported fields
}

WaitGroup is an extension to sync.WaitGroup that provided channel for errors.

func NewWaitGroup() *WaitGroup

NewWaitGroup initializes new *WaitGroup and runs errors collection goroutine.

func (wg *WaitGroup) Add(i int)

Add adds delta to WaitGroup counter.

func (wg *WaitGroup) Done()

Done decrements WaitGroup counter by 1.

func (wg *WaitGroup) ErrChan() chan<- error

ErrChan returns channel for errors.

func (wg *WaitGroup) Wait() error

Wait waits for all goroutines to exit (via Done method) and returns multierror for all errors or nil.