Method AwaitResult

internal/bridge/taskmanager.go:193–199

AwaitResult returns the task's result channel for reading. Callers should read from this channel to receive results routed by the fan-out.

(sessionID string, taskID uint32)

// AwaitResult returns the task's result channel for reading.
// Callers should read from this channel to receive results routed by the fan-out.
func (tm *TaskManager) AwaitResult(sessionID string, taskID uint32) <-chan *sessions.CommandResult {
	task := tm.Get(sessionID, taskID)
	if task == nil {
		return nil
	}
	return task.resultCh
}

// Complete marks a task as completed and closes its result channel.
func (tm *TaskManager) Complete(sessionID string, taskID uint32) {