in tester/run/concurrency.go [19:35]
func LoadTestConcurrencyFixed(r tester.ConcurrencyRunner, o interface{}, ws ...tester.Workers) error {
t := r.Tester()
if err := t.Before(o); err != nil {
//nolint:wrapcheck
return err
}
defer t.After(o)
for _, workers := range ws {
if err := loadTestConcurrency(r, t, o, workers); err != nil {
return err
}
}
return nil
}