Update using cache

rx.java

@Override
    public Observable<Void> onRefreshAction() {
        return Observable.fromEmitter(emitter -> {
            swipeRefreshLayout.setOnRefreshListener(() -> emitter.onNext(null));
            emitter.setCancellation(() -> swipeRefreshLayout.setOnRefreshListener(null));
        }, Emitter.BackpressureMode.ERROR).startWith((Void) null).map(ignored -> null);
    }


addToUnsubscribe(view.onRefreshAction()
                .doOnNext(ignored -> view.showRefreshing(true))
                .switchMap(ignored -> articlesRepository
                        .latestFintechArticles()
                        .subscribeOn(ioScheduler)
                        .observeOn(uiScheduler)
                        .doOnError(throwable -> {
                            view.showRefreshing(false);
                            view.showRefreshingError();
                        })
                        .onErrorResumeNext(throwable -> {
                            Log.e("ArticlesPresenter", "Error refreshing articles", throwable);
                            return Observable.empty();
                        }))
                .observeOn(uiScheduler)
                .doOnNext(ignored -> view.showRefreshing(false))
                .subscribe(view::showArticles));