Function wrapAsyncOp

common/decls/decls.go:987–994

wrapAsyncOp adapts a blocking function into the channel-based AsyncOp used internally. The blocking function is invoked synchronously and its result delivered on a buffered channel. The interpreter always invokes an AsyncOp from a dedicated goroutine, so running the blocking call inline here keeps

(fn functions.BlockingAsyncOp)

// call inline here keeps the framework to a single goroutine per async call rather than spawning
// an additional one to bridge blocking-to-channel.
func wrapAsyncOp(fn functions.BlockingAsyncOp) functions.AsyncOp {
	return func(ctx context.Context, args ...ref.Val) <-chan ref.Val {
		ch := make(chan ref.Val, 1)
		ch <- fn(ctx, args...)
		close(ch)
		return ch
	}
}

// LateFunctionBinding indicates that the function has a binding which is not known at compile time.
// This is useful for functions which have side-effects or are not deterministically computable.