RxJS

Question

ここで条件（グローバル変数の存在）が満たされたときに期待されると、観察完成に結果として働いていたコードのレガシー約束ベースの作品です：

const fooPromise = new Promise(resolve => { 
    const interval = setInterval(() => { 
    if (window.foo) { 
     clearInterval(interval); 
     resolve(window.foo); 
    } 
    }, 100); 
}); 

setTimeout(() => { 
    window.foo = {}; 
}, 1000) 

const foo$ = Rx.Observable.fromPromise(fooPromise); 

foo$.subscribe(
    () => console.log('success'), 
    () => console.log('error'), 
    () => console.log('complete') 
); 

私は「すっきり観測可能な専用ソリューション、fiddleにそれを変換しようとは：m

'use strict'; 

setTimeout(() => { 
    window.foo = {}; 
}, 1000) 

const foo$ = Rx.Observable.interval(100).map(() => foo).retry(-1) 

foo$.subscribe(
    () => console.log('success'), 
    () => console.log('error'), 
    () => console.log('complete') 
); 

私は正しい軌道に乗ってんだけど、観測可能が完了し、値でスパム続けていないように見えます。

これを修正する適切な方法は何ですか？

Answer 1

は1つだけですfooを取るので、take(count) operatorを使用する必要があります。

観察可能な源から放出された唯一の最初のカウント値を出力します。

ソースから最初のカウント値を受け取り、完了します。

const foo$ = Rx.Observable.interval(100).map(() => foo).retry().take(1) 

Fiddle