Wie erhält man den letzten Wert beim Abonnieren eines Observable?

Question

Ich habe zwei Angular2 Komponenten, die Daten über einen Service teilen müssen:

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

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

Es sei ComponentA gemacht wird und es gibt ein Ereignis über SearchService.setSearchResults. Dann navigiert der Benutzer zu ComponentB, der auch searchResult$ abonniert. ComponentB wird jedoch niemals das von ComponentA ausgegebene Ereignis beobachten, da es searchResult$ zur Zeit ComponentA nicht signiert hatte, da ein Ereignis ausgegeben wurde, da es nicht existierte.

Wie kann ich eine Observable erstellen, die das letzte Ereignis an jeden neuen Teilnehmer sendet?

Answer 1

BehaviorSubject emittiert sofort den letzten Wert an neue Abonnenten:

@Injectable() 
export class SearchService { 

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

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

ReplaySubject emittiert alle Vorveranstaltungen um neue Abonnenten.

Answer 2

können Sie die ReplaySubject verwenden, um immer den letzten Wert des Beobachters zu bekommen, so etwas wie dieses:

@Injectable() 
export class SearchService { 

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

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

Und genauso normal abonnieren.
Eine fortgeschrittenere example sind hier zu finden: caching results with angular2 http service