()
| 1341 | } |
| 1342 | let taskPromise = undefined |
| 1343 | function startCheck() { |
| 1344 | if (taskPromise?.isPending) { |
| 1345 | return |
| 1346 | } |
| 1347 | do { |
| 1348 | if (taskPromise?.resolvedValue instanceof Promise) { |
| 1349 | taskPromise = makeQuerablePromise(taskPromise.resolvedValue) |
| 1350 | continue |
| 1351 | } |
| 1352 | if (typeof navigator?.scheduling?.isInputPending === "function" && navigator.scheduling.isInputPending()) { |
| 1353 | return |
| 1354 | } |
| 1355 | const continuePromise = continueTasks().catch(async function (err) { |
| 1356 | console.error(err) |
| 1357 | await eventSource.fireEvent(EVENT_UNHANDLED_REJECTION, { reason: err }) |
| 1358 | await asyncDelay(RETRY_DELAY_ON_ERROR) |
| 1359 | }) |
| 1360 | taskPromise = makeQuerablePromise(continuePromise) |
| 1361 | } while (taskPromise?.isResolved) |
| 1362 | } |
| 1363 | |
| 1364 | const SD = { |
| 1365 | ChunkedStreamReader, |
nothing calls this directly
no test coverage detected