SampleCall.kt

fun sampleCall(api: ServerApi) {
    pagedDataOf { start -> api.getStrings(start, pageLimit = 20) }
            .subscribeOn(Schedulers.io())
            .subscribe(object: Subscriber<List<String>> {
                override fun onSubscribe(subscription: Subscription) {
                    subscription.request(2)
                }

                override fun onNext(nextPage: List<String>) = System.out.println(nextPage)

                override fun onError(t: Throwable) {}
                
                override fun onComplete() {}
            })
}