FinalPaging.kt

fun <TData> pagedDataOf(nextPageStartingFrom: (start: Int) -> Flowable<PagedResponse<TData>>): Flowable<List<TData>> =
              Flowables.generateWith({ 0 }) { start, emitter ->
                  nextPageStartingFrom(start)
                          .doOnNext {
                              it.apply {
                                  values.takeIf { it.isNotEmpty() }?.let { emitter.onNext(it) }
                                  isLastPage.takeIf { it }?.let { emitter.onComplete() }
                              }
                          }
                          .map { it.nextPageStart }
                          .blockingFirst()
              }