Как реализовать кэширование данных в условиях backpressure при использовании RxJava?