Sample Presenter RxJava https://hackernoon.com/yet-another-mvp-article-part-4-rxjava-and-rxandroid-knows-how-to-response-cde42ccc4958

SearchPresenterImpl.java

@Override
public void doSearch(boolean isConnected, String query, long timestamp) {
    if (null != view) {
        view.showProgress();
    }

    subscription = interactor.loadCharacter(query, Constants.PRIVATE_KEY, Constants.PUBLIC_KEY, timestamp)
            // check if result code is OK
            .map(charactersResponse -> {
                if (Constants.CODE_OK == charactersResponse.getCode())
                    return charactersResponse;
                else
                    throw Exceptions.propagate(new ApiResponseCodeException(charactersResponse.getCode(), charactersResponse.getStatus()));
            })
            // check if is there any result
            .map(charactersResponse -> {
                if (charactersResponse.getData().getCount() > 0)
                    return charactersResponse;
                else
                    throw Exceptions.propagate(new NoSuchCharacterException());
            })
            // map CharacterResponse to CharacterModel
            .map(Mapper::mapCharacterResponseToCharacter)
            // cache data on database
            .map(character -> {
                try {
                    databaseHelper.addCharacter(character);
                } catch (SQLException e) {
                    throw Exceptions.propagate(e);
                }

                return character;
            })
            .observeOn(scheduler.mainThread())
            .subscribe(character -> {
                        if (null != view) {
                            view.hideProgress();
                            view.showCharacter(character);

                            if (!isConnected)
                                view.showOfflineMessage();
                        }
                    },
                    // handle exceptions
                    throwable -> {
                        if (null != view) {
                            view.hideProgress();
                        }

                        if (isConnected) {
                            if (null != view) {
                                if (throwable instanceof ApiResponseCodeException)
                                    view.showServiceError((ApiResponseCodeException) throwable);
                                else if (throwable instanceof NoSuchCharacterException)
                                    view.showQueryNoResult();
                                else
                                    view.showRetryMessage(throwable);
                            }
                        } else {
                            if (null != view) {
                                view.showOfflineMessage();
                            }
                        }
                    });
}