DispatchPendingAsyncCalls launches pending asynchronous calls for the specified required call IDs.
(callIDs []int64)
| 251 | |
| 252 | // DispatchPendingAsyncCalls launches pending asynchronous calls for the specified required call IDs. |
| 253 | func (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. |