rxjs Observablesを連結する

Question

複数のオブザーバを連結することは可能ですか？例えば

： 私は3機能があります。

よう

Observable.combine (ensureUserLogged(), createEntity(), checkEntity()).subscribe (
    checkEntityResult => console.log (checkEntityResult), 
    error => console.log (error) 
); 

か何か：私はのような何かやりたい

ensureUserLogged():Observable<boolean> 

createEntity():Observable<Entity> 

checkEntity():Observable<boolean> 

を

ensureUserLogged().then (logged => createEntity()).then (newEntity => checkEntity())... 

をそうでなければ、私がする必要があります醜いピラミッドを書く：

ensureUserLogged().subscribe (
    res => { 
     createEntity().subscribe (
      res => { 
       checkEntity().subscribe (
        res => { console.log ("I'm finally here") }, 
        error {} 
       ) 
      }, 
      err => { 
      } 
     ); 
    }, 
    err => { 
    } 
) 

私の意志を達成するために何かありますか？あなたが並列実行ためObservable.forkJoinを使用する必要が

おかげ

Answer 1

：

Observable.forkJoin(ensureUserLogged(), createEntity(), checkEntity()).subscribe (
    checkEntityResult => console.log (checkEntityResult), 
    error => console.log (error) 
); 

checkEntityResultは、各要素を含む配列に対応する：ensureUserLoggedの結果のための最初のものを、...

をに実行するには、を使用する必要があります0演算子：

ensureUserLogged().flatMap((resultOfEnsureUserLogged) => { 
    return createEntity(); 
}).flatMap((resultOfCreateEntity) => { 
    return checkEntity(); 
}).subscribe((resultOfChekEntity) => { 
    (...) 
}); 

物事を混在させることができます。たとえば、次のようなものです。

ensureUserLogged().flatMap((resultOfEnsureUserLogged) => { 
    return Observable.forJoin(createEntity(), checkEntity()); 
}).subscribe((resultOfCreateEntityAndChekEntity) => { 
    (...) 
});