Advertisement
Guest User

Untitled

a guest
Apr 19th, 2019
101
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.65 KB | None | 0 0
  1. // countdown 10
  2. val observer = object : DisposableObserver<Long>() {
  3. override fun onComplete() {
  4. Timber.d("onComplete")
  5. isLoading.value = false
  6. }
  7.  
  8. override fun onNext(t: Long) {
  9. Timber.d("onNext:$t")
  10.  
  11. }
  12.  
  13. override fun onError(e: Throwable) {
  14. Timber.d("onError:%s",e.message)
  15. isLoading.value = false
  16. }
  17.  
  18. }
  19.  
  20. val timeCount = 10.toLong()
  21.  
  22. Observable.interval(0,1,TimeUnit.SECONDS)
  23. .subscribeOn(Schedulers.io())
  24. .observeOn(AndroidSchedulers.mainThread())
  25. .map {
  26. timeCount-it
  27. }
  28. .take(timeCount)
  29. .doOnSubscribe {
  30. isLoading.value = true
  31. }
  32. .subscribe(observer)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement