Function sendProcessStep

api/controller/relay/relay_process_step.go:127–139

sendProcessStep 发送处理步骤的流式数据

(c *gin.Context, requestId string, step ProcessStep)

// sendProcessStep 发送处理步骤的流式数据
func sendProcessStep(c *gin.Context, requestId string, step ProcessStep) error {
	if shouldSkipProcessStepInCompact(step) {
		return nil
	}
	hashedStep := normalizeProcessStep(step)

	if !isMessageIDFirstFrameSent(c) {
		enqueuePendingProcessStep(c, requestId, hashedStep)
		return nil
	}

	return sendProcessStepRaw(c, requestId, hashedStep)
}

func sendProcessStepRaw(c *gin.Context, requestId string, hashedStep ProcessStep) error {
	if streamDone, exists := c.Get("stream_response_done"); exists {