(items, batchSize, syncEpoch, loadBatch)
| 62 | } |
| 63 | |
| 64 | async function prefetchInBatches(items, batchSize, syncEpoch, loadBatch) { |
| 65 | for (let index = 0; index < items.length && shouldContinue(syncEpoch); index += batchSize) { |
| 66 | await waitForIdle(syncEpoch); |
| 67 | await loadSafely(() => loadBatch(items.slice(index, index + batchSize))); |
| 68 | } |
| 69 | } |
| 70 | |
| 71 | async function prefetchProgramDescriptions(programIds, syncEpoch) { |
| 72 | await prefetchInBatches(programIds, DESCRIPTION_BATCH_SIZE, syncEpoch, (batch) => ( |
no test coverage detected