私はswitchMap、flatMapまたはその他のrxjs演算子をAngularで使うべきでしょうか？

Question

2つのデータストリームがあり、2つ目は最初のものに依存しますが、2番目のストリームの変更をキャッチできます。私はオブザーバブルを作成するための2つの関数を書いた。この実装が正しいかどうか疑問に思っています。

firstObservable(){ 
    ... 
}; 
secondObservable(someValue){ 
    ... 
} 
let subscription = firstObservable().switchMap(r => { 
    if (r.someValue){ 
    return secondObservable(r.someValue); 
    }else{ 
    return Observable.empty(); 
    } 
}).subscribe(...); 

Answer 1

あなたが何を求めているかについて具体的に分かっていれば、それは助けになると思いますが、私が理解しているところからはうまく見えます。

おそらく、flatMapの代わりにswitchMapを使いたいと思っています。 FlatMapは複数の内部サブスクリプションを維持しますが、SwitchMapは最新の内部オブザーバブルへのサブスクリプションのみを維持します。したがって、ソースの出力に基づいて内側のオブザーバブルからのみ値を取得したい場合は、switchMapがそれを行います。

あなたの使用例は不明ですが、Observable.empty（）を返す代わりにフィルタを適用することを検討してください。ここで

は一例です：あなたはむしろflatMapよりswitchMapたいと思うように

const firstObservable = Rx.Observable.create((o) => { 
 
    o.next(); 
 
    setTimeout(() => o.next(1), 1000); 
 
    setTimeout(() => o.next(), 2000); 
 
    setTimeout(() => o.next(2), 3000); 
 
    setTimeout(() => o.complete(), 4000); 
 
}).do(console.log.bind(null, 'first: next'), 
 
    console.log.bind(null, 'first: error'), 
 
    console.log.bind(null, 'first: complete')); 
 
const secondObservable = (x) => Rx.Observable.interval(x * 500).take(5) 
 
    .do(console.log.bind(null, 'second: next'), 
 
    console.log.bind(null, 'second: error'), 
 
    console.log.bind(null, 'second: complete')); 
 

 
firstObservable.filter(x => x).switchMap(x => secondObservable(x)) 
 
    .subscribe(console.log.bind(null, 'stream: next'), 
 
    console.log.bind(null, 'stream: error'), 
 
    console.log.bind(null, 'stream: complete'));

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.5.2/Rx.js"></script>