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

Method Subscribe

pkg/workflow/engine.go:126–126  ·  view source on GitHub ↗
(eventType string, handler EventHandler)

Source from the content-addressed store, hash-verified

124type EventBus interface {
125 Publish(ctx context.Context, event *WorkflowEvent) error
126 Subscribe(eventType string, handler EventHandler) error
127 Unsubscribe(eventType string, handler EventHandler) error
128}
129

Callers 15

forwardAgentEventsMethod · 0.65
ChatStreamHandlerMethod · 0.65
TestAgentEventBusFunction · 0.65
ExecuteMethod · 0.65
ExecuteAsyncMethod · 0.65
SubscribeMethod · 0.65
SubscribeMethod · 0.65
runSessionFunction · 0.65
subscribeToAgentMethod · 0.65
mainFunction · 0.65
mainFunction · 0.65

Calls

no outgoing calls

Tested by 2

TestAgentEventBusFunction · 0.52
SetupTestMethod · 0.52