CryptocurrenciesViewModel.kt

class CryptocurrenciesViewModel @Inject constructor(
    private val cryptocurrencyRepository: CryptocurrencyRepository) : ViewModel() {

  var cryptocurrenciesResult: MutableLiveData<List<Cryptocurrency>> = MutableLiveData()
  var cryptocurrenciesError: MutableLiveData<String> = MutableLiveData()
  lateinit var disposableObserver: DisposableObserver<List<Cryptocurrency>>

  fun cryptocurrenciesResult(): LiveData<List<Cryptocurrency>> {
    return cryptocurrenciesResult
  }

  fun cryptocurrenciesError(): LiveData<String> {
    return cryptocurrenciesError
  }

  fun loadCryptocurrencies() {

    disposableObserver = object : DisposableObserver<List<Cryptocurrency>>() {
      override fun onComplete() {

      }

      override fun onNext(cryptocurrencies: List<Cryptocurrency>) {
        cryptocurrenciesResult.postValue(cryptocurrencies)
      }

      override fun onError(e: Throwable) {
        cryptocurrenciesError.postValue(e.message)
      }
    }

    cryptocurrencyRepository.getCryptocurrencies()
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .debounce(400, MILLISECONDS)
        .subscribe(disposableObserver)
  }

  fun disposeElements(){
    if(null != disposableObserver && !disposableObserver.isDisposed) disposableObserver.dispose()
  }

}