@Test
public void convertsFromAsyncPublisher() {

    Flowable<String> input = Flowable.just("foo")
            .concatWith(Flowable.just("bar", "baz").observeOn(sBackgroundScheduler));
    LiveData<String> liveData = LiveDataReactiveStreams.fromPublisher(input);
    liveData.observe(S_LIFECYCLE_OWNER, mObserver);
    assertThat(mLiveDataOutput, is(Collections.singletonList("foo")));
    sBackgroundScheduler.triggerActions();
    assertThat(mLiveDataOutput, is(Arrays.asList("foo", "bar", "baz")));
}