BaseViewModel.kt

open class BaseViewModel : ViewModel() {

    private val disposableList = mutableListOf<Disposable>()

    // integration with rx
    fun <T> Observable<T>.subscribe(stateLiveData: StateLiveData<T>, successOnFirstValue: Boolean = true) = stateLiveData.post(this, successOnFirstValue).also { disposableList.add(it) }

    override fun onCleared() {
        disposableList.filter { !it.isDisposed }.forEach { it.dispose() }
        disposableList.clear()
        super.onCleared()
    }
}