MovieHunt blog part3. repo modified

MovieRepo.kt

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

class MovieRepoImpl : MovieRepo, KoinComponent {

   override fun fetchMovieList(
       category: MovieCategory,
       pageSize: Int
   ): Listing<MovieModel> {
       val dataSourceFactory = MovieListDataSourceFactory(category)
       val pagedListConfig = PagedList.Config.Builder()
           .setPageSize(DEFAULT_PAGE_SIZE)
           .setEnablePlaceholders(false)
           .build()
       val pagedList = RxPagedListBuilder(dataSourceFactory, pagedListConfig)
           .setFetchScheduler(Schedulers.io())
           .buildObservable()
      return Listing(
         pagedList = pagedList,
         refreshState = dataSourceFactory.initLoadState,
         loadMoreState = dataSourceFactory.loadMoreState,
         refresh = { dataSourceFactory.dataSource?.invalidate() }
      )
   }
}