MovieHunt blog part3 repo

MovieRepo.kt

interface MovieRepo {
   fun fetchMovieList(category: MovieCategory, pageSize: Int = DEFAULT_PAGE_SIZE): Observable<PagedList<MovieModel>>
}

class MovieRepoImpl : MovieRepo, KoinComponent {

   override fun fetchMovieList(
       category: MovieCategory,
       pageSize: Int
   ): Observable<PagedList<MovieModel>> {
       val dataSourceFactory = MovieListDataSourceFactory(category)
       val pagedListConfig = PagedList.Config.Builder()
           .setPageSize(DEFAULT_PAGE_SIZE)
           .setEnablePlaceholders(false)
           .build()
       return RxPagedListBuilder(dataSourceFactory, pagedListConfig)
           .setFetchScheduler(Schedulers.io())
           .buildObservable()
   }
}