Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package id.ihwan.aac.network
- import id.ihwan.aac.model.MovieResponse
- import io.reactivex.android.schedulers.AndroidSchedulers
- import io.reactivex.disposables.CompositeDisposable
- import io.reactivex.schedulers.Schedulers
- class MainRepository {
- private val apiService = ApiFactory.create()
- private val compositeDisposable = CompositeDisposable()
- fun requestMovie(onResult: (MovieResponse) -> Unit, onError: (Throwable) -> Unit){
- apiService.getMovie()
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread())
- .subscribe(object: ApiObserver<MovieResponse>(compositeDisposable){
- override fun onApiSuccess(data: MovieResponse) {
- onResult(data)
- }
- override fun onApiError(er: Throwable) {
- onError(er)
- }
- })
- }
- fun onDestroy(){
- compositeDisposable.clear()
- }
- }
Add Comment
Please, Sign In to add comment