func LoadTestConcurrencyFixed()

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
}