我的应用程序有3个下载按钮
每个按钮单击将调度DownloadFileAction(payload = fileId)
Effect将继续侦听Download_File_Action类型
每个按钮单击将调度DownloadFileAction(payload = fileId)
Effect将继续侦听Download_File_Action类型
@effect()
download_attachment$: Observable = this.actions$
.ofType(FileActions.ActionTypes.DOWNLOAD_ATTACHMENT)
.map(toPayload)
.switchMap( attachment => {
return this.service.downloadAttachment(attachment.link) //absolute link
.map( (data) => {
this.service.saveAttachment(data); //save file locally
return new FileActions.DownloadAttachmentSuccessAction(attachment);
})
.catch(error => {
//debugger;
console.log(error);
});
})
如果同时单击多个按钮,将分派2个DownloadFileAction操作
Howerver,download_attachment $effect只监听一个先下载然后返回DownloadAttachmentSuccessAction,因此其他下载文件将无法完成
解决方法
正如@cartant在评论中提到的那样,将switchMap替换为mergeMap.
不同的是,switchMap将在每次父observable触发时切换上下文,mergeMap将继续监听父observable并合并或合并结果.
SwitchMap
本质上,当父observable发出新值时,switchMap取消订阅父observable的第一个流.
在大理石图中,您可以看到发射3然后发射5时,最终输出不包括3 30秒,因为当发射5时,它切换上下文并且值被删除.
MergeMap
MergeMap将合并从父observable发出的所有值.
在mergeMap的大理石图中,您可以看到从父observable发出的每个值都会发出所有值.即,即使最后一个值在父母发出5之后进入,也会发出所有30个.
希望这有助于更好地说明它.
