NewTaskManager creates a new TaskManager.
()
| 83 | |
| 84 | // NewTaskManager creates a new TaskManager. |
| 85 | func NewTaskManager() *TaskManager { |
| 86 | return &TaskManager{ |
| 87 | tasks: make(map[taskKey]*Task), |
| 88 | subIndex: make(map[string]*Task), |
| 89 | sessionSubs: make(map[string]string), |
| 90 | } |
| 91 | } |
| 92 | |
| 93 | // Create registers a new task in Pending state. |
| 94 | // If a task with the same sessionID+taskID already exists, it is returned as-is. |
no outgoing calls