using rx storage

UsingRxStorage.java

public class JokesPresenter extends BasePresenter<JokesView> {

    private JokesStore store;
    private Subscription subscription;

    @Inject
    public JokesPresenter(JokesStore jokesStore) { this.store = jokesStore; }
    
    @Override
    public void onCreate() {
        super.onCreate();
        fetchNewJoke();
    }

    @Override
    public void onStart() {
        super.onStart();
        subscription = store.register(new JokeSubscriber());
    }

    @Override
    public void onStop() {
        store.unregister(subscription);
        super.onStop();
    }

    void fetchNewJoke() {
        store.onNext(new JokeRequest());
    }

    private class JokeSubscriber extends Subscriber<JokeResponse> {
        //onComplete, onError
        @Override
        public void onNext(JokeResponse jokeResponse) {
            if (jokeResponse.isSuccessful()) {
                view.displayJoke(jokeResponse.getJoke().getValue().getJoke());
            } else {
                view.displayError(jokeResponse.getErrorString());
            }
        }
    }
}