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

Method DispatchPendingAsyncCalls

interpreter/frame.go:253–263  ·  view source on GitHub ↗

DispatchPendingAsyncCalls launches pending asynchronous calls for the specified required call IDs.

(callIDs []int64)

Source from the content-addressed store, hash-verified

251
252// DispatchPendingAsyncCalls launches pending asynchronous calls for the specified required call IDs.
253func (f *ExecutionFrame) DispatchPendingAsyncCalls(callIDs []int64) {
254 if f.ctx == nil || f.ctx.asyncCalls == nil {
255 return
256 }
257 t := f.ctx.asyncCalls
258 for _, callID := range callIDs {
259 if acs := t.getByID(callID); acs != nil {
260 t.launch(f.ctx.ctx, acs, f.ctx.observer)
261 }
262 }
263}
264
265// ActiveAsyncCalls returns the number of async function calls that have been launched
266// but whose completions have not yet been drained.

Calls 2

getByIDMethod · 0.80
launchMethod · 0.80