Advertisement
Guest User

Untitled

a guest
Nov 19th, 2019
116
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Kotlin 0.91 KB | None | 0 0
  1. fun <T> Observable<T>.withTimer(): Observable<T> =
  2.     Observable.zip(this,
  3.         Observable.timer(5000, TimeUnit.MILLISECONDS),
  4.         BiFunction { item, _ -> item })
  5.  
  6.  model.getWishlist()
  7.                 .withTimer()
  8.                 .subscribeOn(Schedulers.io())
  9.                 .observeOn(AndroidSchedulers.mainThread())
  10.                 .subscribe({
  11.                     viewDelegate.hideProgress()
  12.                     if (it.isSuccess()) {
  13.                         viewDelegate.showWishlist(it.responseData)
  14.                     }
  15.                 }, {
  16.                     it.handleError(
  17.                         { viewDelegate.hideProgress() },
  18.                         { viewDelegate.onNoInternetConnection() },
  19.                         { errorMessage -> viewDelegate.onError(errorMessage) },
  20.                         { messageId -> viewDelegate.onError(messageId) }
  21.                     )
  22.                 })
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement