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 }