Cómo señalar un observable para producir más datos

¿Hay alguna manera de indicarle a un observable que produzca más datos?

Tengo un Observable almacenado que produce 10 elementos y quiero que continúe produciendo más elementos solo cuando quiera.

Para ser más específico, tengo una vista infinita de Recycler en desplazamiento, quiero producir más elementos solo cuando continúo desplazándome hasta el final.

Suponiendo que ya tiene algún tipo de fuente de datos con presión de retroceso.

Puede usar request (n) para informar a su fuente de datos que está listo para más artículos.

Lo que puedes hacer es tener un Observer que emita events scrool de página, llamémoslo paginador.

En cada emisión puedes cambiar a otro observador que aporte más datos,

  paginator .onBackpressureDrop() .map { lastVisibleIndex -> (lastVisibleIndex + 2) / PAGE_SIZE + 1 } .distinct() .concatMap { page -> getCollectionsObservable(page, pageSize) } .subscribeWith(GetCollectionObserver()) ) } 
  • ¿Cómo especificar la versión de RxJava al usar RxKotlin?
  • No se puede llamar al operador desde () en Observable en Android Kotlin
  • RxJava2 switchIfEmpty y verificando una ejecución
  • RxJava usando Kotlin - cómo sincronizar 2 methods asíncronos, refactorizar desde Java
  • Comportamiento impar de TestObserver al suscribirse a un Asunto
  • ¿Cómo se coordina una list de ejecuciones Completables con RxJava?
  • Reescriba el código de Java en Kotlin utilizando la reference de function.
  • Cómo controlar el flujo sin .flatMap, que rompe una stream reactiva que impide que operadores como distinctUntilChanged trabajen en toda la secuencia
  • Excepción causada por: java.lang.ClassNotFoundException: org.reactivestreams.Publisher
  • Cambio observable a condición cumplida - RxJava2
  • RxJava BehaviorSubject no emite el último elemento?