MCPcopy Create free account
hub / github.com/astercloud/aster / WithTimeout

Method WithTimeout

pkg/workflow/router.go:190–193  ·  view source on GitHub ↗

WithTimeout 设置超时

(timeout time.Duration)

Source from the content-addressed store, hash-verified

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

Callers 15

ExecuteMethod · 0.45
WaitForCompletionFunction · 0.45
TestPTCIntegrationFunction · 0.45
checkPythonAiohttpFunction · 0.45
ExecuteMethod · 0.45
ExecuteMethod · 0.45
ExecuteMethod · 0.45
execWithLimitsMethod · 0.45
execDirectMethod · 0.45
StartSubagentMethod · 0.45
NewRedisStoreFunction · 0.45

Implementers 1

StaticRouterpkg/router/router.go

Calls

no outgoing calls

Tested by 7

TestPTCIntegrationFunction · 0.36
checkPythonAiohttpFunction · 0.36
setupTestServerFunction · 0.36
SetupTestMethod · 0.36