RxJS Observable - 条件が満たされるたびに1回購読する

Question

Observablesは私には新しいものなので、それが可能であるかどうかはわかりません（しかし、それは推測できます）。私が達成したいのは、観測値（Angular 2 http.get呼び出し）を持っていて、変数が変更されたときにに一度を登録することです。

let x = false; 
// ... somewhere later I change "x" to true 
subscribe gets called once, x => false 
// stuffs happening, 10 minutes later x => true again 
subscribe gets called once, x => false 

大きなコンセプトはのlocalStorageでトークンの変更があるたびに、私はUserServiceを持っているでしょうし、コンストラクタで、私は一度/api/user/meを購読するだろうということです。例の流れはこのようなものになるだろう。これは有効なユースケースですか、もしそうなら、私はどのようにオブザーバブルでそれを行うことができますか？このような

Answer 1

何かがトリックを行う必要があります：あなたはAPI呼び出しをトリガーしたいとき

// Observable that on subscription will result in an api call. It would 
// naturaly have another type in an acaual use case. 
let apiCallObservable : Rx.Observable< { someResult: any }>; 

let localStorageChangedObservable = new Rx.Subject<boolean>() 

localStorageChangedObservable 
    // only care about local storage change if not null 
    // This is just an example the type of localStorageChangedObservable 
    // could be anything you want, and you could check anything you want in the 
    // "where" 
    .where(v => v != null) 
    .selectMany(() => 
     // Take one is to make sure we terminate apiCallObservable after recieving 
     // one result from it. 
     apiCallObservable.take(1)) 
    .subscribe(
     (result: { someResult: any}) => { 

      // here we would have the result from the call to apiCallObservable 
     }); 

// To execute the chain abouve we would pass values to the localStorageChangedObservable 
// subject like this: 

localStorageChangedObservable.onNext(true); // results in api call and result in subscribe 
localStorageChangedObservable.onNext(null); // results in nothing. 
localStorageChangedObservable.onNext(false); // results in api call and result in subscribe 

をしたがって、基本的localStorageChangedObservable.onNext(...)に何かを渡します。