rxjs - 主题的 RxJS 主题
问题描述
我正在尝试创建一个下载资产列表的主题,该列表为每个资产发送操作,如果可能的话,使用主题的主题?
export function onDownloadGuide(action$,store){
return action$.ofType(DOWNLOAD_GUIDE)
.mergeMap(() => downloadGuideAssets().map(res => downloadGuideAssetProgress(res)))
}
function downloadGuideAssets(){
const subject$ = new Subject()
getAssetList().map((asset) => downloadAsset(asset).map(res => {console.log(res);subject$.next(res)}))
return subject$.asObservable()
}
function downloadAsset({id,src}){
const subject$ = new Subject()
window.resolveLocalFileSystemURL(cordova.file.dataDirectory, dirEntry => {
dirEntry.getFile(src.substring(src.lastIndexOf('/')+1),{create:true, exclusive:true}, f => {
fetch(src).then(fetchProgress({onProgress(progress) {console.log('progressevent');subject$.next({id,progress})}}))
.then(res => res.blob())
.then(blob =>
f.createWriter(writer => {
writer.onwriteend = ()=> subject$.next({id,complete:true})
writer.write(blob)
}))
.catch(err => subject$.next({id,error:err}))
}, err => subject$.next({id,error:err}) )
})
return subject$.asObservable()
}
这些文件似乎正在下载等。我可以控制台记录进度 - 当我尝试映射结果时,什么都没有被触发。
这是因为我是从订阅开始的吗?
解决方案
它可以像下面这样进一步简化并像这样使用它downloadGuideAssets().subscribe()
,你真的不需要一个主题
function downloadGuideAssets(){
return getAssetList().map((asset) => downloadAsset(asset))
}
function downloadAsset({id,src}){
return Observable.create(obs=>{
window.resolveLocalFileSystemURL(cordova.file.dataDirectory, dirEntry => {
dirEntry.getFile(src.substring(src.lastIndexOf('/')+1),{create:true, exclusive:false}, f => {
fetch(src).then(fetchProgress({onProgress(progress) {subject$.next({id,progress})}}))
.then(res => res.blob())
.then(blob =>
f.createWriter(writer => {
writer.onwriteend = ()=> obs.next({id,complete:true})
writer.write(blob)
}))
.catch(err => obs.error({id,error:err}))
}, err => obs.error({id,error:err}) )
})
})
}
推荐阅读
- python - 应用日期时间刻度
- java - 我创建了一个 android wear 应用程序,代码编译正确,但在模拟器中它一直停止,是什么原因造成的?
- java - 为什么 MySQL 连接长时间保持在 CLOSE_WAIT 状态?
- android - 如何在浏览器中使用内部存储数据更新 android webview
- php - 从 codeigniter 加载的视图生成图像
- google-cloud-ml - 如何保存从 gcloud ml 引擎获得的预测?
- android - React Native - 这两个应用程序之间有什么区别,其中一个使用 `AppRegistry.registerComponent` 而另一个不使用?
- python-3.x - 如何访问已下载图像 Scrapy 的本地路径
- java - java.lang.ExceptionInInitializerError:java.security.AccessControlException:访问被拒绝(java.lang.RuntimePermission loadLibrary.jacob)WEBUTIL
- java - 为什么 Quartz Scheduler 运行两次?