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 contar el time de ejecución de lo observable
  • rxjava2 - ejemplo simple de ejecutar tareas en un grupo de subprocesss, suscribirse en un solo hilo
  • JsonArray a la class de datos de Kotlin con Retrofit (se esperaba BEGIN_OBJECT pero era BEGIN_ARRAY)
  • Reescriba el código de Java en Kotlin utilizando la reference de function.
  • Sitio de Android con RxJava manejar resultado de consulta vacío
  • RxJava Debounce onNext ()
  • Solicitud en Android siempre dando exception de time de espera del socket
  • HttpException no capturado por onError ()
  • Ingrese los valores propios para combinarlos
  • EXCEPCIÓN FATAL: RxCachedThreadScheduler-1 cuando el gatillo se deshace. ¿Por qué?
  • ¿Hay alguna manera de cambiar mi método a la stream Observable que será una cadena de modificadores?