[pagination avec rxjava] pagination avec rxjava #android #rxjava #rx

paginate.java

    private void downloadDataWhenDiscussionUnresolved(String numPage) {
        Observable<Discussions> operationObservable = getDiscussionsObservable(numPage);

        operationObservable.subscribe(new Subscriber<Discussions>() {
            @Override
            public void onCompleted() {
                Log.d(TAG, "onCompleted() called");
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(Discussions discussions) {
                Log.d(TAG, "onNext() called with: discussions = [" + discussions + "]");
                downloadDataWhenDiscussionUnresolved(discussions.getNextPage());
            }
        });
    }

    @NonNull
    private Observable<Discussions> getDiscussionsObservable(final String numPage) {
        return Observable.create(new Observable.OnSubscribe<Discussions>() {
            @Override
            public void call(Subscriber<? super Discussions> subscriber) {

                subscribe(discussionManager.getDiscussionsUnResolved(numPage), discussions -> {

                    refreshData(discussions, null != mDiscussions);

                    if (null != discussions && null != discussions.getNextPage() && mDiscussions.getDiscussions().size() < 10) {
                        subscriber.onNext(discussions);
                    } else {
                        subscriber.onCompleted();
                    }
                }, new ObserverError() {
                    @Override
                    public void onError(Throwable error) {
                        subscriber.onError(error);
                    }
                });
            }
        });
    }