livedata通知新的观察者

Question

在livedata的observe方法中有这样一条评论

在给定所有者的生命周期内将给定的观察者添加到观察者列表中。事件在主线程上分派。如果LiveData已经有数据集，它将传递给观察者。

当我尝试向现有livedata实例添加新的观察者时，如果livedata具有数据集，则new观察者的onChanged方法调用。

有什么办法可以避免这种行为吗？我只是不想被通知新的观察员

SingleLiveEvent没有完全报道我的案子

Answer 1

由于LiveData从其默认版本-1启动了Observators版本，因此新的观察者会从之前的LiveData值更改中获得通知。下面是livedata的ObserverWrapper类

private abstract class ObserverWrapper {
    final Observer<T> mObserver;
    boolean mActive;
    int mLastVersion = START_VERSION;

    ObserverWrapper(Observer<T> observer) {
        mObserver = observer;
    }

    abstract boolean shouldBeActive();

    ...rest of class ...
    }

相反，我创建了定制的ObserverWrapper，并从livedata的上一个版本启动了新的观察者。

public class MyObserverWrapper<T> {
final Observer<T> observer;
int lastVersion;

public MyObserverWrapper(Observer<T> observer, int version) {
    this.observer = observer;
    lastVersion = version;
}
}

在我的自定义livedata类中，我检查了观察者的版本是否小于livedata的版本。如果是这样，我通知了观察者。

public class SingleLiveEvent<T> extends MutableLiveData<T> {

public int version;
private MyObserverWrapper observerWrapper;
private Map<String, MyObserverWrapper> observerWrapperMap = new HashMap<>();

public void observe(LifecycleOwner owner, MyObserverWrapper observerWrapper) {
    observerWrapperMap.put(owner.getClass().getName(), observerWrapper);
    observe(owner, observerWrapper.observer);
}

@MainThread
public void observe(final LifecycleOwner owner, final Observer<T> observer) {

    // Observe the internal MutableLiveData
    super.observe(owner, new Observer<T>() {
        @Override
        public void onChanged(@Nullable T t) {
            for (String lifecycleOwnerName : observerWrapperMap.keySet()) {
                if (lifecycleOwnerName.equals(owner.getClass().getName())) {
                    observerWrapper = observerWrapperMap.get(lifecycleOwnerName);
                    break;
                }
            }
            if (observerWrapper.lastVersion < version) {
                observer.onChanged(t);
            }
        }
    });
}

@MainThread
public void setValue(@Nullable T t) {
    version++;
    super.setValue(t);
}
}