(parallelOption: number | ((data: any) => number) | undefined)
| 374 | } |
| 375 | |
| 376 | export function determineMaxLimit(parallelOption: number | ((data: any) => number) | undefined) { |
| 377 | const parallelCount = typeof parallelOption === 'function' ? parallelOption(null) : (parallelOption ?? 1) |
| 378 | |
| 379 | const maxLimit = Math.max(1, parallelCount) |
| 380 | return maxLimit |
| 381 | } |
| 382 | |
| 383 | export async function drainQueue( |
| 384 | state: { promises: Promise<any>[], draining: boolean }, |
no outgoing calls
no test coverage detected