[yesnoapi-rxjava-example] AnswerViewModel.kt

class AnswerViewModel (
    private val answerRepository: AnswerRepository
): ViewModel() {

    private var disposable: Disposable? = null

    val answer by lazy {
        MutableLiveData<Result<Answer>>()
    }

    override fun onCleared() {
        super.onCleared()
        disposable?.dispose()
    }

    fun loadAnswer() {
        disposable =
            answerRepository.getAnswer()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(
                    { value -> answer.setValue(Result.Success(value))},
                    { error -> answer.setValue(Result.Failure(error))},
                    { println("Getting answer completed")}
                )
    }
}