Method executeAll

plugin/studio/testrun/test_run_command.go:133–170

(params []testRunParams, ctx plugin.ExecutionContext, logger log.Logger)

}

func (c TestRunCommand) executeAll(params []testRunParams, ctx plugin.ExecutionContext, logger log.Logger) ([]testRunStatus, error) {
	statusChannel := make(chan testRunStatus)
	var wg sync.WaitGroup
	for _, p := range params {
		wg.Add(1)
		go c.execute(p, ctx, p.Logger, &wg, statusChannel)
	}

	go func() {
		wg.Wait()
		close(statusChannel)
	}()

	var progressBar *visualization.ProgressBar
	if !ctx.Debug {
		progressBar = visualization.NewProgressBar(logger)
		defer progressBar.Remove()
	}
	once := sync.Once{}
	progress := c.showPackagingProgress(progressBar)
	defer once.Do(func() { close(progress) })

	status := make([]testRunStatus, len(params))
	for s := range statusChannel {
		once.Do(func() { close(progress) })
		status[s.ExecutionId] = s
		c.updateProgressBar(progressBar, status)
	}

	results := []testRunStatus{}
	for _, s := range status {
		if s.Err != nil {
			return nil, s.Err
		}
		results = append(results, s)
	}
	return results, nil
}

func (c TestRunCommand) updateProgressBar(progressBar *visualization.ProgressBar, status []testRunStatus) {
	if progressBar == nil {