Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- fun <T> Observable<T>.withTimer(): Observable<T> =
- Observable.zip(this,
- Observable.timer(5000, TimeUnit.MILLISECONDS),
- BiFunction { item, _ -> item })
- model.getWishlist()
- .withTimer()
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread())
- .subscribe({
- viewDelegate.hideProgress()
- if (it.isSuccess()) {
- viewDelegate.showWishlist(it.responseData)
- }
- }, {
- it.handleError(
- { viewDelegate.hideProgress() },
- { viewDelegate.onNoInternetConnection() },
- { errorMessage -> viewDelegate.onError(errorMessage) },
- { messageId -> viewDelegate.onError(messageId) }
- )
- })
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement