func()

in unison/safewaitgroup.go [57:71]


func (s *SafeWaitGroup) Add(n int) error {
	if n < 0 {
		s.wg.Add(n)
		return nil
	}

	s.mu.RLock()
	defer s.mu.RUnlock()
	if s.closed {
		return ErrGroupClosed
	}

	s.wg.Add(n)
	return nil
}