Method executeStreamingWorkflow

pkg/workflow/workflow_agent.go:117–138

executeStreamingWorkflow 执行 workflow（流式）

(ctx context.Context, input *WorkflowInput)

// executeStreamingWorkflow 执行 workflow（流式）
func (wa *WorkflowAgent) executeStreamingWorkflow(ctx context.Context, input *WorkflowInput) (any, error) {
	resultChan := make(chan any, 100)

	go func() {
		defer close(resultChan)

		reader := wa.workflow.Execute(ctx, input)
		for {
			event, err := reader.Recv()
			if err != nil {
				if errors.Is(err, io.EOF) {
					break
				}
				resultChan <- map[string]any{"error": err.Error()}
				continue
			}
			resultChan <- event
		}
	}()

	return resultChan, nil
}

// formatOutput 格式化输出为字符串
func (wa *WorkflowAgent) formatOutput(output any) string {