EfeBudak

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    ...

    mPresenter = new Presenter(
            fragment,
            SchedulerProvider.getInstance(),
            Repository.getInstance(
                    LocalDataSource.getInstance(),

EfeBudak

private void getPage() {
    mCompositeDisposable.add(mRepository.getPage(mCurrentPage)
            .observeOn(mSchedulerProvider.ui())
            .subscribeOn(mSchedulerProvider.io())
            .subscribeWith(new DisposableSingleObserver<Products>(){

                @Override
                public void onSuccess( @io.reactivex.annotations.NonNull Products products) {
                    mView.setRefreshing(false);
                    mView.refreshPageItems(products.getProducts());

EfeBudak

mRecyclerView.addOnScrollListener(new RecyclerView.OnScrollListener() {
    @Override
    public void onScrolled(RecyclerView recyclerView, int dx, int dy) {
        super.onScrolled(recyclerView, dx, dy);
        int visibleItemCount = recyclerView.getLayoutManager().getChildCount();
        int totalItemCount = recyclerView.getLayoutManager().getItemCount();
        int firstVisibleItemPosition = ((LinearLayoutManager) recyclerView.getLayoutManager()).findFirstVisibleItemPosition();

        if (!mSwipeRefreshLayout.isRefreshing() && !mEndOfList) {
            if ((visibleItemCount + firstVisibleItemPosition) >= totalItemCount - Constants.PAGINATION_MARGIN

EfeBudak

@Override
public void onLoadNextPage() {
    mCurrentPage++;
    mView.setRefreshing(true);
    getPage();
}
@Override
public void onRefresh() {
    mCurrentPage = 0;
    mView.setRefreshing(true);