Как преобразовать горячий поток в холодный и наоборот в RxJava?

Преобразование горячего потока в холодный и наоборот в RxJava достигается с помощью операторов:

Горячий в Холодный (например, из Subject)

Используется оператор hide(). Он возвращает Observable, который имитирует холодное поведение, скрывая тип источника.

java

Холодный в Горячий

Используются операторы publish() и connect(). publish() преобразует холодный Observable в ConnectableObservable, который не начинает эмиссию данных до вызова connect(). Множество подписчиков до вызова connect() будут получать одни и те же данные.

java

Также можно использовать оператор share(). Это упрощенный вариант сочетания publish().refCount(). Он делает Observable горячим, но начинает эмиссию только при наличии хотя бы одного подписчика и останавливает, когда подписчиков нет.

java

Оператор cache() также делает поток горячим, но он также кэширует все данные, эмитированные источником, и ретранслирует их новым подписчикам.

java