您好,我使用来自 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);
})