A parallel set of tasks, this starts each child task and offers up an output channel that is a merger of each child --> \ --> - -> --> /
| 23 | // --> - -> |
| 24 | // --> / |
| 25 | type TaskParallel struct { |
| 26 | *TaskBase |
| 27 | in TaskRunner |
| 28 | runners []TaskRunner |
| 29 | tasks []Task |
| 30 | } |
| 31 | |
| 32 | func NewTaskParallel(ctx *plan.Context) *TaskParallel { |
| 33 | return &TaskParallel{ |
nothing calls this directly
no outgoing calls
no test coverage detected