RxJS Ab (используя) map function Observables

Question

В моем устройстве Angular2 у меня есть компонент, который вызывает метод обслуживания. Метод службы возвращает Observable, и компонент подписывается на него.

Как я хочу, чтобы служба кэшировала последние вызовы, я бы перехватил данные в Observable с помощью функции map. Метод образцового обслуживания выглядит следующим образом

provideData():Observable<Data> { 
    return this.http.get(url). 
    map(resp => resp.json()). 
    map(data => { 
      this.cachedData = _.cloneDeep(data); 
      return data; 
    } 
} 

Этот подход работает для меня, однако, я не уверен, если я не злоупотребляю функцию map которая ничего не отображает. Это просто перехватчик для хранения данных. Есть ли лучшие или более рекомендуемые способы?

PS: Это не обязательно относится к кешированию, а не к соответствующему использованию функции map для операций без отображения. In this question Широко одобренный ответ Günter действительно делает то же самое и использует для этого map. С другой стороны, пользователь olsn заявил в комментариях, что do будет еще более уместным.

Answer 1

PublishReplay делает вашу многоадресную рассылку потоков и кэширует поток источника.

provideData():Observable<Data> { 
    return this.http.get(url) 
    .map(resp => resp.json()) 
    .publishReplay(); 
} 

Для экстенсивного объяснения, как это работает оператор посмотреть на Making a lazy, cached observable that only execute the source once