diff --git a/src/logic/download-manager.spec.ts b/src/logic/download-manager.spec.ts index 375b3cf6..8e057910 100644 --- a/src/logic/download-manager.spec.ts +++ b/src/logic/download-manager.spec.ts @@ -153,6 +153,7 @@ describe("download-manager", () => { test("should forcibly stopped while downloading", async () => { let counter = 0 + ;(fetch as ReturnType).mockReset() ;(fetch as ReturnType).mockImplementation(async (url) => { // await sleep(500) if (counter++ > 5) return Promise.reject(new Error("time_out")) @@ -221,6 +222,7 @@ describe("download-manager", () => { test("should continue while downloading", async () => { let counter = 0 + ;(fetch as ReturnType).mockReset() ;(fetch as ReturnType).mockImplementation(async (url) => { // await sleep(500) if (counter++ > 5) return Promise.reject(new Error("time_out")) diff --git a/src/logic/download-manager.ts b/src/logic/download-manager.ts index cd08e341..6473ed1d 100644 --- a/src/logic/download-manager.ts +++ b/src/logic/download-manager.ts @@ -1,7 +1,6 @@ /* eslint-disable functional/no-throw-statement */ /* eslint-disable camelcase */ import hashSum from "hash-sum" -import { mapLimit } from "modern-async" /* . @@ -71,7 +70,7 @@ async function downloadFiles( downloading: Ref, onprogress: (cur: number, total: number, path: string) => void ): Promise { - await mapLimit( + await someLimit( sources, async (src: string, index: number) => { if (src.startsWith(PROTOCOL_OFFLINE)) return false