Convert RxJava:Observable<T> to AAC:LiveData<T>

ObservableExtensions.kt

package your.awesome.package

import android.arch.lifecycle.LiveData
import android.arch.lifecycle.MutableLiveData
import io.reactivex.Observable
import io.reactivex.disposables.Disposable

fun <T> Observable<T>.toLiveData() : LiveData<T> {

    return object : MutableLiveData<T>() {
        var disposable : Disposable? = null;

        override fun onActive() {
            super.onActive()

            // Observable -> LiveData
            disposable = this@toLiveData.subscribe({
                this.postValue(it)
            })
        }

        override fun onInactive() {
            disposable?.dispose();
            super.onInactive()
        }
    }
}