Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
interface PostRepository {
fun getFeeds(): Observable<PagedList<Post>>
}
class PostRepositoryImpl : PostRepository {
override fun getFeeds(): Observable<PagedList<Post>> {
val dataSource = PostPagingDataSourceFactory()
val pagedListConfig = PagedList.Config.Builder()
.setPageSize(10)
.setPrefetchDistance(4)
.build()
return RxPagedListBuilder(dataSource, pagedListConfig)
.setFetchScheduler(Schedulers.io())
.setNotifyScheduler(AndroidSchedulers.mainThread())
.buildObservable()
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.