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

Function AsyncCompletionBufferSize

cel/options.go:763–768  ·  view source on GitHub ↗

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

(size int)

Source from the content-addressed store, hash-verified

761// AsyncCompletionBufferSize sets the size of the buffer for the async completion channel.
762// By default, the channel is unbuffered.
763func AsyncCompletionBufferSize(size int) ProgramOption {
764 return func(p *prog) (*prog, error) {
765 p.asyncCompletionBufferSize = size
766 return p, nil
767 }
768}
769
770// AsyncMaxConcurrency sets the maximum number of concurrently launched async calls during
771// ConcurrentEval. This bounds the number of in-flight async goroutines, so a wide fan-out (such

Callers 1

TestConcurrentEvalFunction · 0.92

Calls

no outgoing calls

Tested by 1

TestConcurrentEvalFunction · 0.74