()
| 56 | } |
| 57 | |
| 58 | func (t *Task) InputChan() chan reflect.Value { |
| 59 | if len(t.InputChans) != 1 { |
| 60 | log.Panicf("This should not happen! task %s input should be only one instead of %d", t.Name(), len(t.InputChans)) |
| 61 | } |
| 62 | return t.InputChans[0] |
| 63 | } |
| 64 | |
| 65 | func (t *Task) AddInputChan(ch chan reflect.Value) { |
| 66 | t.InputChans = append(t.InputChans, ch) |
no test coverage detected