Function AsyncCallObserver

cel/options.go:754–759

AsyncCallObserver sets the observer for monitoring asynchronous function calls during ConcurrentEval.

(observer async.Observer)

// AsyncCallObserver sets the observer for monitoring asynchronous function calls during ConcurrentEval.
func AsyncCallObserver(observer async.Observer) ProgramOption {
	return func(p *prog) (*prog, error) {
		p.asyncObserver = observer
		return p, nil
	}
}

// AsyncCompletionBufferSize sets the size of the buffer for the async completion channel.
// By default, the channel is unbuffered.