ReactiveArchitecture_NowPlaingActivity_meatGrinder.java

compositeDisposable.add(RxRecyclerView.scrollEvents(nowPlayingBinding.recyclerView)
        .flatMap(recyclerViewScrollEvent -> {
            if (scrollEventCalculator.isAtScrollEnd()) {
                return Observable.just(new ScrollEvent(pageNumber + 1));
            } else {
                return Observable.empty();
            }
        })
        .debounce(scrollEvent -> Observable.<ScrollEvent>empty().delay(250, TimeUnit.MILLISECONDS))
        .subscribe(scrollEvent -> nowPlayingViewModel.processUiEvent(scrollEvent), throwable -> {
            throw new UnsupportedOperationException("Errors in scroll event unsupported. Crash app.");
        })
);