in mobius-android/src/main/java/com/spotify/mobius/android/MutableLiveQueue.java [91:105]
public void setObserver(
@Nonnull LifecycleOwner lifecycleOwner,
@Nonnull Observer<T> liveObserver,
@Nullable Observer<Iterable<T>> pausedObserver) {
if (lifecycleOwner.getLifecycle().getCurrentState() == DESTROYED) {
return; // ignore
}
synchronized (lock) {
this.liveObserver = liveObserver;
this.pausedObserver = pausedObserver;
this.lifecycleOwnerIsPaused = true;
lifecycleOwner.getLifecycle().addObserver(new LifecycleObserverHelper());
ignoreBackgroundEffects = false;
}
}