Rxjs處理錯誤在單獨的管道和合並

Question

我想在錯誤Observable分成的Observable兩股

catch運營商可以通過throw ING返回一個觀察或傳播錯誤兩種或返回Observable.throw

錯誤轉化爲有效

partition運營商只處理有效的值，沒有錯誤通過這個

我需要的是分裂Observable成兩個Observable秒的d過程則不同，它們合併如下圖所看到的

Answer 1

模式這樣可能適合你的使用情況

step1 
 
    .map((data)=>{data:data}) 
 
    .catch(()=>Observable.of({error:'error'}) 
 
    .flatMap((res)=>{ 
 
    //process A and B should return observable 
 
    if(res.data) return processA(res) 
 
    return processB(res) 
 
    }) 
 
    .map(res=>{ 
 
    //do your merged processing here 
 
    }) 
 
    .subscribe()