Complete notes that the task is completed by closing the Updates channel and yields the logger to the next Task. Complete blocks until the *tasklog.Logger has acknowledged completion of this task.
()
| 44 | // yields the logger to the next Task. Complete blocks until the *tasklog.Logger |
| 45 | // has acknowledged completion of this task. |
| 46 | func (s *SimpleTask) Complete() { |
| 47 | s.wg.Add(1) |
| 48 | close(s.ch) |
| 49 | s.wg.Wait() |
| 50 | } |
| 51 | |
| 52 | // OnComplete implements an interface which receives a call to this method when |
| 53 | // the *tasklog.Logger has finished processing this task, but before it has |