UsersRepository.kt

class UsersRepository @Inject constructor(
    var dataSourceFactory: UsersDataSourceFactory
) {
    fun getUsers(): Observable<PagedList<User>> {
        val config = PagedList.Config.Builder()
                .setInitialLoadSizeHint(SO_PAGE_SIZE)
                .setPageSize(SO_PAGE_SIZE)
                .build()
        val users: Observable<PagedList<User>> = 
        RxPagedListBuilder(dataSourceFactory, config)
                .setInitialLoadKey(1)
                .setFetchScheduler(Schedulers.io())
                .setNotifyScheduler(AndroidSchedulers.mainThread())
                .buildObservable()
        return users
    }

    fun getDataLoadStatus(): Observable<NetworkState> {
        return dataSourceFactory.observableEmitter.switchMap { dataSource ->
            dataSource.loadState
        }
    }
}