Method handleStream

pkg/agent/actor.go:315–344

handleStream 处理流式对话

(_ *actor.Context, msg *StreamMsg)

// handleStream 处理流式对话
func (a *AgentActor) handleStream(_ *actor.Context, msg *StreamMsg) {
	execCtx, cancel := a.withCancellation(msg.Ctx)
	defer cancel()

	go func() {
		reader := a.agent.Stream(execCtx, msg.Text)

		for {
			event, err := reader.Recv()
			if err != nil {
				// EOF 或错误
				if msg.EventCh != nil {
					msg.EventCh <- &StreamEventMsg{
						Type:  "done",
						Error: err,
					}
					close(msg.EventCh)
				}
				return
			}

			if event != nil && msg.EventCh != nil {
				msg.EventCh <- &StreamEventMsg{
					Type:    "event",
					Content: event,
				}
			}
		}
	}()
}

// handleToolCall 处理工具调用
func (a *AgentActor) handleToolCall(ctx *actor.Context, msg *ToolCallMsg) {