LiveDataの基礎的な性質を整理する。

    LiveData<SourceValueType> sourceData = (略);
    MediatorLiveData<XXX> mediatorData = (略);
    mediatorData.addSource(sourceData, new Observer<SourceValueType>() {
        @Override
        public void onChanged(@Nullable SourceValueType data) {
            // addSource()で設定したObserverは、sourceDataのObserverとして扱われる。
            // sourceDataからの通知に応じて、ここに任意の処理を実施する。
        }
    });

public class StubLifecycleOwner implements LifecycleOwner {
    private final LifecycleRegistry registry = new LifecycleRegistry(this);

    @NonNull
    @Override
    public Lifecycle getLifecycle() {
        return registry;
    }
    public void markInitialized() {
        registry.markState(Lifecycle.State.INITIALIZED);
    }
    public void markCreated() {
        registry.markState(Lifecycle.State.CREATED);
    }
    public void markStarted() {
        registry.markState(Lifecycle.State.STARTED);
    }
    public void markResumed() {
        registry.markState(Lifecycle.State.RESUMED);
    }
    public void markDestroyed() {
        registry.markState(Lifecycle.State.DESTROYED);
    }
}

@RunWith(JUnit4.class)
public class LiveDataTest {

    @Rule
    public InstantTaskExecutorRule instantExecutorRule = new InstantTaskExecutorRule();

    @Test
    public void testSubscribe() {
        StubLifecycleOwner owner = new StubLifecycleOwner();
        Observer<Long> observer = mock(Observer.class);
        MutableLiveData<Long> liveData = new MutableLiveData<>();
        // Observerが非アクティブ
        owner.markCreated();
        liveData.observe(owner, observer);
        // 非アクティブ時のsetValue
        liveData.setValue(1L);
        // 即座に通知されない
        verify(observer, never()).onChanged(anyLong());
        // Observerがアクティブ
        owner.markStarted();
        // (b) 次回アクティブ時に通知
        verify(observer).onChanged(1L);
    }
}