RxJS 5 и альтернативы оператору кеша

Question

Перед обновлением RxJS до 5.0.0-rc.0 Я использовал .cache(), чтобы разделить подписку в моем приложении с угловым выражением. Большим преимуществом в использовании этого было то, что любая новая подписка получит последнее опубликованное значение.

Команда RxJS решил убрать его, и теперь я считаю себя вручную проводкой личного BehaviorSubject или ReplaySubject и затем вызвать .asObservable() всего времени. Это похоже на много шаблонов, учитывая тот простой способ, которым мы должны были это сделать раньше.

Я пропустил какой-то более простой способ? Я не могу найти оператора .replay(), и операторы .share() и .publishReplay(), похоже, тоже не делают этого.

Спасибо!

Answer 1

Это то, что я использую, чтобы показать RxJS. В следующем примере кэшируется последний издевавшийся HTTP-ответ в течение 1 секунды. Он основан на многоадресной рассылке RxJS через publishReplay() и refCount().

var counter = 1; 
var updateTrigger = Observable.defer(() => mockDataFetch()) 
    .publishReplay(1, 1000) 
    .refCount() 
    .take(1); 

function mockDataFetch() { 
    return Observable.of(counter++) 
     .delay(100); 
} 

function mockHttpCache() { 
    return updateTrigger; 
} 

mockHttpCache().toPromise() 
    .then(val => console.log("Response from 0:", val)); 

setTimeout(() => mockHttpCache().toPromise() 
    .then(val => console.log("Response from 200:", val)) 
, 200); 

setTimeout(() => mockHttpCache().toPromise() 
    .then(val => console.log("Response from 1200:", val)) 
, 1200); 

setTimeout(() => mockHttpCache().toPromise() 
    .then(val => console.log("Response from 1500:", val)) 
, 1500); 

setTimeout(() => mockHttpCache().toPromise() 
    .then(val => console.log("Response from 3500:", val)) 
, 3500); 

Смотреть демо: https://jsbin.com/todude/3/edit?js,console

Это выводит на консоль:

Response 0: 1 
Response 50: 1 
Response 200: 1 
Response 1200: 2 
Response 1500: 2 
Response 3500: 3