Блог

У меня есть метод кэширования в контейнере:

 get(): Observable<T[]> {
  if (!this.get$) {
    this.get$ = merge(
      this.behaviorSubject.asObservable(),
      this._config.get().pipe(shareReplay(1), tap(x => this.behaviorSubject.next(x))));
  }

  return this.get$;
}
 

Это прекрасно работает с обычными наблюдаемыми объектами, однако, когда я кэширую нижеприведенное в myContainer2 (например, используя результат кэшированного наблюдаемого для создания другого кэшированного наблюдаемого), например:

 // get is assigned to _config.get in the above function
const myContainer2 = new Container({get: () => myContainer1.get().pipe(mergeMap(res1 => getObs2(res1))});

// please note, the end goal is to resolve the first observable on the first subscription 
// and not when caching it in the above method (using cold observables)
myContainer2.get().subscribe(...) // getObs2 gets called
myContainer2.get().subscribe(...) // getObs2 gets called again
myContainer2.get().subscribe(...) // getObs2 gets called for a third time, and so on
 

каждый раз, когда второй кэш подписывается на getObs2, вызывается (он ничего не кэширует).
Я подозреваю, что моя реализация get ошибочна, так как я объединяю объект поведения (который излучает в начале), но я не могу придумать никакого другого способа его реализации (чтобы использовать холодные наблюдаемые).
Пожалуйста, обратите внимание, что если я использую обычный наблюдаемый вместо MyContainer.get (), все работает так, как ожидалось.
Вы знаете, в чем заключается проблема?

Используя декларативный подход, вы можете обрабатывать кэширование следующим образом:

 // Declare the Observable that retrieves the set of 
// configuration data and shares it.
config$ = this._config.get().pipe(shareReplay(1));
 

При подписке на config$ приведенный выше код автоматически получит конфигурацию, если она еще не была получена, или вернет полученную конфигурацию.

Я не совсем понимаю, для чего предназначен код BehaviorSubject в вашем примере. Если это должно было содержать исходящие данные конфигурации, в этом нет необходимости, так как config$ они будут предоставлены.