WithTimeout 设置超时
(timeout time.Duration)
| 188 | |
| 189 | // WithTimeout 设置超时 |
| 190 | func (r *Router) WithTimeout(timeout time.Duration) *Router { |
| 191 | r.config.Timeout = timeout |
| 192 | return r |
| 193 | } |
| 194 | |
| 195 | // ExecuteStream 流式执行 Router - 支持实时事件流 |
| 196 | func (r *Router) ExecuteStream(ctx context.Context, input *StepInput, streamEvents bool) *stream.Reader[any] { |
no outgoing calls