Come ottenere l'ultimo valore quando si sottoscrive un Osservabile?

Question

Ho due componenti Angular2 che hanno bisogno di condividere i dati tramite un servizio:

@Injectable() 
export class SearchService { 
    private searchResultSource = new Subject<string>() 
    searchResult$ = this.searchResultSource.asObservable() 

    setSearchResults(_searchResult: string): void { 
    this.searchResultSource.next(_searchResult) 
    } 
} 

Supponiamo ComponentA è resa ed emette un evento tramite SearchService.setSearchResults. Quindi l'utente passa a ComponentB, che si abbona anche a searchResult$. Tuttavia, ComponentB non osserverà mai l'evento emesso da ComponentA perché non è stato sottoscritto a searchResult$ al momento ComponentA emesso un evento, poiché non esisteva.

Come è possibile creare un Observable che emette l'ultimo evento per ogni nuovo utente?

Answer 1

BehaviorSubject emette immediatamente l'ultimo valore ai nuovi abbonati:

@Injectable() 
export class SearchService { 

    private searchResultSource = new BehaviorSubject<string>(1); 

    setSearchResults(_searchResult: string): void { 
     this.searchResultSource.next(_searchResult); 
    } 
} 

ReplaySubject emette tutti gli eventi precedenti per i nuovi abbonati.

Answer 2

È possibile utilizzare il ReplaySubject per ottenere sempre l'ultimo valore della Observer, qualcosa di simile:

@Injectable() 
export class SearchService { 

    private searchResultSource = new ReplaySubject<string>(1); 

    setSearchResults(_searchResult: string): void { 
     this.searchResultSource.next(_searchResult); 
    } 
} 

E basta iscriversi come normale.
una più avanzata example può essere trovato qui: caching results with angular2 http service