0

您好,我使用来自 rxjs 的 mergemap。我使用对象数组。

const list = [{name:'test',url:'https.....'}.....]
const source = from(list)
.pipe(mergeMap(getFile, null, 4))
.subscribe(saveDB);

在我的 getFile 函数中,我使用 axios 将文件下载到 blob 并订阅保存。现在让我们说我想取消所有进程,我只是返回承诺拒绝,或者如果继续解决。有没有更好的办法?

我的目标是下载新文件。获取文件

return new Promise(async (resolve, reject) => {
      //change on click for example
      if (!downloadInProgress) {
        reject("finish");
      }
      const dataToSave = {
        ...val,
        blob: new Blob([response.data], { type: val.type }),
      };
      resolve(dataToSave);

})
4

0 回答 0