LookupByCommand returns the task associated with a command ID, or nil.
(cmdID string)
| 183 | |
| 184 | // LookupByCommand returns the task associated with a command ID, or nil. |
| 185 | func (tm *TaskManager) LookupByCommand(cmdID string) *Task { |
| 186 | tm.mu.RLock() |
| 187 | defer tm.mu.RUnlock() |
| 188 | return tm.subIndex[cmdID] |
| 189 | } |
| 190 | |
| 191 | // AwaitResult returns the task's result channel for reading. |
| 192 | // Callers should read from this channel to receive results routed by the fan-out. |
no outgoing calls