resolveAsyncMaxConcurrency maps the configured concurrency to the effective launch limit: - 0 (unset): apply defaultAsyncMaxConcurrency. - >0: use the configured value. - <0: unlimited (no launch limiter); use only if the caller bounds concurrency another way.
(configured int)
| 478 | // - >0: use the configured value. |
| 479 | // - <0: unlimited (no launch limiter); use only if the caller bounds concurrency another way. |
| 480 | func resolveAsyncMaxConcurrency(configured int) int { |
| 481 | if configured == 0 { |
| 482 | return defaultAsyncMaxConcurrency |
| 483 | } |
| 484 | return configured |
| 485 | } |
| 486 | |
| 487 | // resolveCompletionBufferSize returns the size of the async completion channel. When unset, it |
| 488 | // defaults to the effective launch concurrency so that all in-flight calls can report completion |
no outgoing calls
no test coverage detected