jakub.dyszkiewicz
03/27/2017, 6:08 PMprivate var loading: Boolean = false
fun loadPosts(size: Int = 20, lastId: Int = Integer.MAX_VALUE) {
if (loading) {
return
}
loading = true
Observable.fromCallable { postRepository.findLatest(size, lastId) }
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe {
posts.addAll(it)
view.displayPosts(posts)
loading = false
}
}