func loadTestConcurrency()

in tester/run/concurrency.go [69:92]

• 17 lines of code
• 4 McCabe index (conditional complexity)

func loadTestConcurrency(r tester.ConcurrencyRunner, t tester.Tester, o interface{}, workers tester.Workers) error {
	if err := t.BeforeEach(o); err != nil {
		//nolint:wrapcheck
		return err
	}
	defer t.AfterEach(o)

	if err := r.Before(workers, o); err != nil {
		//nolint:wrapcheck
		return err
	}
	defer r.After(workers, o)

	executor, err := t.RequestExecutor(o)
	if err != nil {
		//nolint:wrapcheck
		return err
	}

	bender.LoadTestConcurrency(r.WorkerSemaphore(), r.Requests(), executor, r.Recorder())
	bender.Record(r.Recorder(), r.Recorders()...)

	return nil
}