Method monitorProgress

pkg/agent/subagent.go:576–596

monitorProgress 监控子 Agent 进度

(ctx context.Context, handle *SubAgentHandle, eventCh <-chan types.AgentEventEnvelope)

// monitorProgress 监控子 Agent 进度
func (m *SubAgentManager) monitorProgress(ctx context.Context, handle *SubAgentHandle, eventCh <-chan types.AgentEventEnvelope) {
	for {
		select {
		case <-ctx.Done():
			return
		case env, ok := <-eventCh:
			if !ok {
				return
			}
			// 转换事件为进度事件
			progressEvent := m.convertToProgressEvent(handle, env)
			if progressEvent != nil {
				select {
				case handle.ProgressChan <- progressEvent:
				default:
					// 通道满了，跳过
				}
			}
		}
	}
}

// forwardProgress 转发进度事件
func (m *SubAgentManager) forwardProgress(ctx context.Context, handle *SubAgentHandle, eventCh <-chan types.AgentEventEnvelope, progressChan chan<- *types.SubAgentProgressEvent) {