Rxjs gérer l'erreur dans la canalisation séparée et fusion

Question

Je veux diviser Observable en deux courants de Observable en cas d'erreur

opérateur catch peut convertir erreur en cours de validité en renvoyant une erreur observable ou propager soit par throw ment ou retour Observable.throw

opérateur partition ne traite que des valeurs valides, aucune erreur passent par ce

ce que je dois est divisé en deux Observable un s Observable processus d alors différemment et les fusionner comme on le voit dans schéma ci-dessous

Answer 1

Motif comme cela pourrait s'adapter à votre cas d'utilisation

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