Method NewTask

flow/step_task.go:20–24

()

}

func (step *Step) NewTask() (task *Task) {
	task = &Task{Step: step, Id: len(step.Tasks)}
	step.Tasks = append(step.Tasks, task)
	return
}

// source ->w:ds:r -> task -> w:ds:r
// source close next ds' w chan