MCPcopy Create free account
hub / github.com/cel-expr/cel-go / AsyncObserver

Interface AsyncObserver

interpreter/async.go:48–53  ·  view source on GitHub ↗

Async extension function support. CEL supports `types.Unknown` as a first-class value, and concurrent (async) function execution in CEL invokes a stub function which checks for the presence of an existing result which matches the function call and call arguments, or which records the 'unexecuted' f

Source from the content-addressed store, hash-verified

46// when it completes. The two callbacks therefore run on different goroutines, and OnCallFinished
47// callbacks for distinct calls may run concurrently with each other.
48type AsyncObserver interface {
49 // OnCallStarted is called when an asynchronous function is first launched.
50 OnCallStarted(callID int64, function, overload string, args []ref.Val)
51 // OnCallFinished is called when an asynchronous function completes.
52 OnCallFinished(callID int64, function, overload string, res ref.Val)
53}
54
55// AsyncCall describes a pending or completed asynchronous function call.
56type AsyncCall interface {

Callers 2

launchMethod · 0.65
launchMethod · 0.65

Implementers 3

recordingObserverWithCallbackinterpreter/async_test.go
recordingObserverinterpreter/async_test.go
countingObservercel/program_async_test.go

Calls

no outgoing calls

Tested by

no test coverage detected