Method ComputeResult

interpreter/frame.go:240–250

ComputeResult tracks and computes the result of the given asynchronous function. The first invocation for a given (node id, args) tuple registers the call state and returns an Unknown which references the call's unique callID. Subsequent invocations return the cached result once the call has comple

(id int64, function, overload string, impl functions.AsyncOp, argVals []ref.Val)

// result once the call has completed. Launching background execution is deferred to post-execution
// dispatch via DispatchPendingAsyncCalls.
func (f *ExecutionFrame) ComputeResult(id int64, function, overload string, impl functions.AsyncOp, argVals []ref.Val) ref.Val {
	if f.ctx == nil || f.ctx.asyncCalls == nil {
		return types.NewErrWithNodeID(id, "asynchronous function calls require concurrent evaluation and cannot be resolved by a synchronous Eval")
	}
	t := f.ctx.asyncCalls
	acs := t.getOrCreate(id, function, overload, argVals, impl, f.ctx.gate)
	if res := acs.ResultOrUnknown(); res != nil {
		return res
	}
	return types.NewUnknown(acs.callID, nil)
}

// DispatchPendingAsyncCalls launches pending asynchronous calls for the specified required call IDs.
func (f *ExecutionFrame) DispatchPendingAsyncCalls(callIDs []int64) {