RxJS Observable - abonnieren Sie jedes Mal, wenn eine Bedingung erfüllt

Question

Observables sind neu für mich, also bin ich nicht einmal sicher, ob es möglich ist (aber ich würde es vermuten). Was ich erreichen möchte, ist eine beobachtbare (Angular 2 http.get Aufruf), und abonnieren Sie einmal immer wenn eine Variable geändert wird. Ein Beispiel fließen würde wie folgt sein:

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 

Je größer Konzept ist, dass ich ein UserService und im Konstruktor hätte ich /api/user/me einmal anmelden würde, wenn es eine Token Änderung der localstorage ist. Ist das ein gültiger Anwendungsfall, und wenn ja, wie kann ich das mit Observablen machen?

Answer 1

So etwas sollte es tun:

// 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 

So passiert im Grunde etwas localStorageChangedObservable.onNext(...), wenn Sie einen API-Aufruf auslösen sollen.