AsyncCompletionBufferSize sets the size of the buffer for the async completion channel. By default, the channel is unbuffered.
(size int)
| 761 | // AsyncCompletionBufferSize sets the size of the buffer for the async completion channel. |
| 762 | // By default, the channel is unbuffered. |
| 763 | func 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 |
no outgoing calls