RxDataStore implementation

JokesStore.java

public class JokesStore extends RxStore<JokeRequest, JokeResponse> {
    
    private JokesEndpoint endpoints;
    
    @Inject
    public JokesStore(JokesEndpoint endpoints) {
        this.endpoints = endpoints;
    }

    @Override
    protected Observable.Transformer<JokeRequest, JokeResponse> getTransformer() {
        return new Observable.Transformer<JokeRequest, JokeResponse>() {
            @Override
            public Observable<JokeResponse> call(Observable<JokeRequest> jokeRequestObservable) {
                return jokeRequestObservable.onBackpressureDrop()
                        .observeOn(Schedulers.io())
                        .flatMap(new Func1<JokeRequest, Observable<JokeResponse>>() {
                            @Override
                            public Observable<JokeResponse> call(final JokeRequest jokeRequest) {
                                if (!jokeRequest.wasConsumed()) {
                                    jokeRequest.setConsumed(true);
                                    return network();
                                } else {
                                    jokeRequest.setConsumed(true);
                                    return Observable.concat(memory(), network()).first();
                                }
                            }
                        }).observeOn(AndroidSchedulers.mainThread());
            }
        };
    }

    private Observable<JokeResponse> network() {} //see implementation on github repository
    private Observable<JokeResponse> memory() {}      
}