Revert "dev"

This reverts commit cb8eacbfc3fc76be3977e2aa31c7bc6eb5f9e8e1.

Author: Celoria

backend/modules/prompt/application/debug.go

@@ -234,10 +234,8 @@ func (p *PromptDebugApplicationImpl) doDebugStreaming(ctx context.Context, req *
 	// execute
 	resultStream := make(chan *entity.Reply)
 	errChan := make(chan error)
-	replyChan := make(chan *entity.Reply, 1)
 	goroutine.GoSafe(ctx, func() {
 		var executeErr error
-		var localReply *entity.Reply
 		defer func() {
 			e := recover()
 			if e != nil {
@@ -249,15 +247,13 @@ func (p *PromptDebugApplicationImpl) doDebugStreaming(ctx context.Context, req *
 				errChan <- executeErr
 			}
 			close(errChan)
-			replyChan <- localReply
-			close(replyChan)
 		}()
 		defer func() {
 			// 写入调试记录
 			logErr := p.saveDebugLog(context.WithoutCancel(ctx), saveDebugLogParam{
 				prompt:          prompt,
 				startTime:       startTime,
-				result:          localReply,
+				result:          aggregatedReply,
 				err:             executeErr,
 				singleStepDebug: req.GetSingleStepDebug(),
 			})
@@ -273,7 +269,7 @@ func (p *PromptDebugApplicationImpl) doDebugStreaming(ctx context.Context, req *
 		if executeErr != nil {
 			return
 		}
-		localReply, executeErr = p.promptService.ExecuteStreaming(ctx, service.ExecuteStreamingParam{
+		aggregatedReply, executeErr = p.promptService.ExecuteStreaming(ctx, service.ExecuteStreamingParam{
 			ExecuteParam: service.ExecuteParam{
 				Prompt:        prompt,
 				Messages:      messages,
@@ -337,7 +333,6 @@ func (p *PromptDebugApplicationImpl) doDebugStreaming(ctx context.Context, req *
 				logs.CtxError(ctx, "debug streaming failed, err=%v", err)
 			}
 		}
-		aggregatedReply = <-replyChan
 		return aggregatedReply, err
 	}
 }