Method handleSend

pkg/agent/actor.go:265–279

handleSend 处理发送消息（异步）

(ctx *actor.Context, msg *SendMsg)

// handleSend 处理发送消息（异步）
func (a *AgentActor) handleSend(ctx *actor.Context, msg *SendMsg) {
	execCtx, cancel := a.withCancellation(msg.Ctx)
	defer cancel()

	go func() {
		err := a.agent.Send(execCtx, msg.Text)

		if err != nil && !errors.Is(err, context.Canceled) {
			a.recordError(err)
			if ctx.Sender != nil {
				ctx.Reply(&ErrorMsg{Error: err, Context: "send"})
			}
		}
	}()
}

// handleChat 处理同步对话
func (a *AgentActor) handleChat(ctx *actor.Context, msg *ChatMsg) {