Remove FIXME ...
(taskId uint64)
| 80 | |
| 81 | // Remove FIXME ... |
| 82 | func (rt *RunningTask) Remove(taskId uint64) (context.CancelFunc, errors.Error) { |
| 83 | rt.mu.Lock() |
| 84 | defer rt.mu.Unlock() |
| 85 | if d, ok := rt.tasks[taskId]; ok { |
| 86 | delete(rt.tasks, taskId) |
| 87 | return d.Cancel, nil |
| 88 | } |
| 89 | return nil, errors.NotFound.New(fmt.Sprintf("task with id %d not found", taskId)) |
| 90 | } |
| 91 | |
| 92 | var runningTasks RunningTask |
| 93 |
no test coverage detected