Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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
- }
- }
- }
Add Comment
Please, Sign In to add comment