(step ProcessStep)
| 116 | } |
| 117 | |
| 118 | func (ps *ProcessSender) recordProcessStep(step ProcessStep) { |
| 119 | if ps == nil || ps.messageStatus == nil || ps.c == nil { |
| 120 | return |
| 121 | } |
| 122 | eid := config.GetEID(ps.c) |
| 123 | recordProcessStepForHistory(ps.c.Request.Context(), eid, ps.messageStatus, ps.requestId, step) |
| 124 | } |
| 125 | |
| 126 | // sendProcessStep 发送处理步骤的流式数据 |
| 127 | func sendProcessStep(c *gin.Context, requestId string, step ProcessStep) error { |
no test coverage detected