Как кэшировать реактивный издатель вроде Observable?

Question

Я пытаюсь понять, что произойдет, если я кэширую результат метода, возвращающего холодный наблюдаемый? Поток еще не материализован, так что собственно кеш содержит? Я попытался выяснить использование Hazelcast и Spring Boot, но не смог получить работу кеша.

Редактировать: Когда я говорю, что кеш не работает, я говорю на основе того, что я вижу из Центра управления Hazelcast. В зависимости от конфигурации кеша (я пробовал много вещей), либо кеш отображается, но нет записей, либо кеш не отображается вообще.

Пример:

@javax.cache.annotation.CacheResult 
Observable<Integer> random() { 
    // Do I get a new number every time? 
    return Observable.just(new Random().nextInt()); 
} 

Answer 1

Из ого-Java вик (источник here):

Холодных Наблюдаемые излучает определенную последовательность элементов, но может начать излучающие эту последовательность, когда ее наблюдатель находит это должно быть удобно, и любой ценой, которую желает Наблюдатель, не нарушая целостности последовательности . Например, если вы конвертируете статический Iterable в наблюдаемый, то Observable будет издать одну и ту же последовательность элементов независимо от того, когда она будет позже подписана или как часто эти элементы наблюдаются. Примеры элементов, испускаемых холодным Observable, могут включать в себя результаты запроса базы данных, файл поиск или веб-запрос.

С холодным Observable, как и ваш пример, запрос выполняется в течение подписки, для каждого абонента. Даже без кеша, если вы дважды подписываетесь на тот же номер Observable, запрос будет происходить дважды. Observable не привязан к определенному потоку. Observable - это просто контракт, описывающий доступ к данным.

Кэширование результата метода, возвращающего Observable, я думаю, что это похоже на сохранение результата в локальном свойстве; вы просто не сможете снова воссоздать объект Observable. Но просто «геттер», а не данные.

rx-java предоставляет некоторые инструменты для достижения кеширования самостоятельно. Вы можете взглянуть на Subject или ConnectableObservable.