Method Go

aibridge/utils/concurrent_group.go:23–33

(fn func() error)

}

func (c *ConcurrentGroup) Go(fn func() error) {
	c.wg.Add(1)
	go func() {
		defer c.wg.Done()
		if err := fn(); err != nil {
			c.errsMu.Lock()
			c.errs = multierror.Append(c.errs, err)
			c.errsMu.Unlock()
		}
	}()
}

func (c *ConcurrentGroup) Wait() error {
	c.wg.Wait()