【 提问须知 】

[KunMinX]

如有 bug，请另外 new 一个 issue ⚠️⚠️⚠️

本项目开 issue 规范：

1. 有任何 bug 都欢迎及时开 issue，我看到后予以处理。
2. 如有使用上的疑问，请先认真阅读 Readme 和源码 sample，在没有找到答案后，另外开 issue。
3. 如开 issue 是为了发表个人见解，请务必 客观、具体、严谨；严禁草率、乱入、带节奏：

务必注明观点所对应的场景，并附上完整可复现的代码，

不然缺乏一致的前提依据来有效交流！

任何缺乏实证依据和因果逻辑的泛泛而谈，都可能对其他使用者造成困扰。

在发表个人见解前，请先确保自己认真阅读过源码。这是对自己、对作者、对其他读者最起码的尊重。

[KunMinX]

对于 “凭空想象，胡乱提问，就等着别人来答复” 等违规行为，一律删，

—— 若真的想了解，可以自行动手去实际验证，不然很难让人回复这无中生有的问题。

[KunMinX]

public class ProtectedUnPeekLiveData<T> extends LiveData<T> {

  private final static int START_VERSION = -1;

  private final AtomicInteger mCurrentVersion = new AtomicInteger(START_VERSION);

  protected boolean isAllowNullValue;

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

  @Override
  public void observeForever(@NonNull Observer<? super T> observer) {
    super.observeForever(createObserverWrapper(observer, mCurrentVersion.get()));
  }

  public void observeSticky(@NonNull LifecycleOwner owner, @NonNull Observer<T> observer) {
    super.observe(owner, createObserverWrapper(observer, START_VERSION));
  }

  public void observeStickyForever(@NonNull Observer<? super T> observer) {
    super.observeForever(createObserverWrapper(observer, START_VERSION));
  }

  @Override
  protected void setValue(T value) {
    mCurrentVersion.getAndIncrement();
    super.setValue(value);
  }

  class ObserverWrapper implements Observer<T> {
    private final Observer<? super T> mObserver;
    private int mVersion = START_VERSION;

    public ObserverWrapper(@NonNull Observer<? super T> observer, int version) {
      this.mObserver = observer;
      this.mVersion = version;
    }

    @Override
    public void onChanged(T t) {
      if (mCurrentVersion.get() > mVersion && (t != null || isAllowNullValue)) {
        mObserver.onChanged(t);
      }
    }

    @SuppressWarnings("unchecked")
    @Override
    public boolean equals(Object o) {
      if (this == o) {
        return true;
      }
      if (o == null || getClass() != o.getClass()) {
        return false;
      }
      ObserverWrapper that = (ObserverWrapper) o;
      return Objects.equals(mObserver, that.mObserver);
    }

    @Override
    public int hashCode() {
      return Objects.hash(mObserver);
    }
  }

  @Override
  public void removeObserver(@NonNull Observer<? super T> observer) {
    if (observer.getClass().isAssignableFrom(ObserverWrapper.class)) {
      super.removeObserver(observer);
    } else {
      super.removeObserver(createObserverWrapper(observer, START_VERSION));
    }
  }

  private ObserverWrapper createObserverWrapper(@NonNull Observer<? super T> observer, int version) {
    return new ObserverWrapper(observer, version);
  }

  public void clear() {
    super.setValue(null);
  }
}

[zhaoxiuyu]

MVI架构对State集中管理，可以用这个库来做吗 或者可以封装一下吗。依赖库的minSdk为23是不是有点高。。。

[KunMinX]

@zhaoxiuyu

无需另行封装，已在多个项目如此使用。

https://juejin.cn/pin/7110918498024423437

android studio 创建新项目默认 23 起。google 官方也已宣布放弃 21 以下 SDK 支持。

另请勿于本页面提 issue，不久后即删。