Soy bastante nuevo en rxJava. En mi respuesta de API, obtengo información sobre el número total de páginas y el número de página actual como:

 "pages": 22,
 "page": 1,

Estoy usando Retrofit para hacer llamadas de API en la capa de datos, mi servicio de API es como:

@GET("/story")
    Observable <StoryCollectionEntity> storyCollection(
              @Query("feed_ids") String feed_items, 
              @Query("page") int  page);

entonces:

   public Observable<StoryCollectionEntity> storyCollection() {
        return mUserApi.storyCollection(items,page);
}

Hice la suscripción en la capa de dominio de esta manera:

public void execute(Subscriber UseCaseSubscriber) {
        this.subscription = this.buildUseCaseObservable()
                 .subscribeOn(Schedulers.from(threadExecutor))
                .observeOn(postExecutionThread.getScheduler())
                .subscribe(UseCaseSubscriber);

    }
 @Override public Observable buildUseCaseObservable() {
    return this.userRepository.stories();
  }

Estoy averiguando cómo puedo hacer que este observador reaccione al evento de desplazamiento de recyclerView emitiendo el resultado de la página siguiente. es decir, la página 2 al segundo evento de desplazamiento y la página 3 sobre el tercer desplazamiento ... etc.