CRUD

DBTry.java

    public Observable<Response<Page<GenericItem>>> fetchFeed(int offset, int limit) {
        return endpoint.getFeed(offset, limit)
                .compose(SchedulerProvider.NETWORK.<Response<Page<GenericItem>>>applySchedulers())
                .compose(new Observable.Transformer<Response<Page<GenericItem>>, Response<Page<GenericItem>>>() {
                    @Override
                    public Observable<Response<Page<GenericItem>>> call(Observable<Response<Page<GenericItem>>> responseObservable) {
                        return responseObservable.observeOn(Schedulers.newThread())
                                .subscribeOn(AndroidSchedulers.mainThread())
                                .map(new Func1<Response<Page<GenericItem>>, Response<Page<GenericItem>>>() {
                                    @Override
                                    public Response<Page<GenericItem>> call(Response<Page<GenericItem>> pageResponse) {
                                        // Do something db CRUD
                                        return null;
                                    }
                                });
                    }
                })
                .retryWhen(new RetryWithDelay(3, 500));
    }