RxJava endless scroll listener

EndlessScroll

package com.example;

import android.support.v7.widget.LinearLayoutManager;
import android.support.v7.widget.RecyclerView;

import io.reactivex.Observable;
import io.reactivex.subjects.BehaviorSubject;

/**
 * Created by eliasbagley on 3/29/17.
 */

public class EndlessScroll {
    private boolean loading = false;
    private int                 pastVisiblesItems;
    private int                 visibleItemCount;
    private int                 totalItemCount;
    private LinearLayoutManager layoutManager;
    private BehaviorSubject<Object> onLoadMore = BehaviorSubject.create();

    // extended from http://stackoverflow.com/questions/26543131/how-to-implement-endless-list-with-recyclerview
    public EndlessScroll(RecyclerView recyclerView, LinearLayoutManager manager) {
        this.layoutManager = manager;

        recyclerView.addOnScrollListener(new RecyclerView.OnScrollListener() {
            @Override
            public void onScrolled(RecyclerView recyclerView, int dx, int dy) {
                if (dy > 0) { // scroll down
                    visibleItemCount = layoutManager.getChildCount();
                    totalItemCount = layoutManager.getItemCount();
                    pastVisiblesItems = layoutManager.findFirstVisibleItemPosition();

                    // if we're not currently loading data and we're near the end of the list, then trigger a load
                    if (!loading && isNearEnd()) {
                        setLoading(true);
                        loadMore();
                    }
                }
            }
        });

        // trigger off a request so the list will start with a page of data
        loadMore();
    }


    public synchronized void setLoading(boolean loading) {
        this.loading = loading;
    }


    public Observable<Object> onLoadMore() {
        return onLoadMore;
    }

    // region private methods

    private void loadMore() {
        onLoadMore.onNext(1);
    }

    private boolean isNearEnd() {
        // start a load once we're 90% down the list
        return (pastVisiblesItems + visibleItemCount >= (0.90 * totalItemCount));
    }

    //endregion
}