(port string)
| 16 | } |
| 17 | |
| 18 | func NewTaskGenerator(port string) *TaskGenerator { |
| 19 | gen := &TaskGenerator{ |
| 20 | ports: utils.ParsePortsString(port), |
| 21 | tasks: make(chan *Task), |
| 22 | In: make(chan *Task), |
| 23 | } |
| 24 | |
| 25 | go func() { |
| 26 | for task := range gen.In { |
| 27 | gen.tasks <- task |
| 28 | } |
| 29 | close(gen.tasks) |
| 30 | }() |
| 31 | return gen |
| 32 | |
| 33 | } |
| 34 | |
| 35 | type TaskGenerator struct { |
| 36 | Name string |