observables - que es un observable angular

¿Cómo obtener el último valor al suscribirse a un observable?

Question

Tengo dos componentes Angular2 que necesitan compartir datos a través de un servicio:

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

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

Supongamos que ComponentA se representa y emite un evento a través de SearchService.setSearchResults . Luego, el usuario navega a ComponentB , que también se suscribe a searchResult$ . Sin embargo, ComponentB nunca observará el evento emitido por ComponentA porque no estaba suscrito a searchResult$ en el momento en que ComponentA emitió un evento, ya que no existía.

¿Cómo puedo crear un Observable que emita el último evento a cada nuevo suscriptor?

Answer 1

Puedes usar ReplaySubject para obtener siempre el último valor del Observer, algo como esto:

@Injectable()
export class SearchService {

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

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

Y solo suscríbete como de costumbre.
Puede encontrar un example más avanzado aquí: example

Answer 2

BehaviorSubject emite inmediatamente el último valor a los nuevos suscriptores:

@Injectable()
export class SearchService {

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

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

ReplaySubject emite todos los eventos anteriores a los nuevos suscriptores.