Rxjs 在单独的管道中处理错误并合并

Question

我要拆分Observable分为两个流 Observable错误

catch运算符可以通过返回可观察到的错误或通过 throw 传播错误来将错误转换为有效正在或返回 Observable.throw

partition运算符只处理有效值，没有错误通过这个

我需要的是split Observable一分为二Observable然后以不同的方式处理并合并它们，如下图所示

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()