實(shí)現(xiàn)非粘性的LiveData
https://github.com/WLHere/Snippet/blob/master/util/NonStickyLiveData.java

public class NonStickyLiveData<T> extends LiveData<T> {
    private ConcurrentHashMap<Observer, ObserverWrapper> observerMapping = new ConcurrentHashMap<>();

    @Override
    public void observe(@NonNull LifecycleOwner owner, @NonNull Observer<? super T> observer) {
        super.observe(owner, wrap(observer));
    }

    @Override
    public void observeForever(@NonNull Observer<? super T> observer) {
        super.observeForever(wrap(observer));
    }

    @Override
    public void removeObserver(@NonNull Observer<? super T> observer) {
        ObserverWrapper wrapper = observerMapping.remove(observer);
        if (wrapper != null) {
            super.removeObserver(wrapper);
        } else {
            super.removeObserver(observer);
        }
    }

    @Override
    public void postValue(T value) {
        super.postValue(value);
    }

    @Override
    public void setValue(T value) {
        super.setValue(value);
    }

    private Observer wrap(Observer<? super T> observer) {
        ObserverWrapper proxyObserver = observerMapping.get(observer);
        if (proxyObserver == null) {
            proxyObserver = new ObserverWrapper(observer);
            observerMapping.put(observer, proxyObserver);
        }
        return proxyObserver;
    }

    /**
     * 包裝observer?？梢院雎缘谝淮蔚膐nChanged回調(diào)
     * @param <T>
     */
    private class ObserverWrapper<T> implements Observer<T> {
        private final Observer targetObserver;
        private boolean ignoreOnce;

        public ObserverWrapper(Observer targetObserver) {
            this.targetObserver = targetObserver;
            this.ignoreOnce = getValue() != null;
        }

        @Override
        public void onChanged(T t) {
            if (ignoreOnce) {
                ignoreOnce = false;
            } else {
                targetObserver.onChanged(t);
            }
        }
    }
}