HybridMutableLiveData

HybridMutableLiveData.kt

class HybridMutableLiveData<T> : MutableLiveData<T>() {

    private val pending = AtomicBoolean(false)
    private val sticky = AtomicBoolean(false)

    @MainThread
    override fun observe(owner: LifecycleOwner, observer: Observer<T>) {

        // Observe the internal MutableLiveData
        super.observe(owner, Observer { t ->
            if (sticky.get() || pending.compareAndSet(true, false)) {
                observer.onChanged(t)
            }
        })
    }

    @MainThread
    override fun setValue(t: T?) {
        pending.set(true)
        super.setValue(t)
    }

    override fun postValue(value: T) {
        postValue(value, false)
    }

    fun postValue(t: T?, sticky: Boolean = false) {
        this.sticky.set(sticky)
        super.postValue(t)
    }
}