testexecutor

type ControlChannels struct {
	ReqCtx         <-chan *a2asrv.RequestContext
	ExecEvent      chan<- a2a.Event
	CancelCalled   <-chan struct{}
	ContinueCancel chan<- struct{}
}

type TestAgentExecutor struct {
	ExecuteFn func(context.Context, *a2asrv.RequestContext, eventqueue.Queue) error
	CleanupFn func(context.Context, *a2asrv.RequestContext, a2a.SendMessageResult, error)
	CancelFn  func(context.Context, *a2asrv.RequestContext, eventqueue.Queue) error
	// contains filtered or unexported fields
}