@Test
public void convertsFromPublisher() {

    PublishProcessor<String> processor = PublishProcessor.create();
    LiveData<String> liveData = LiveDataReactiveStreams.fromPublisher(processor);
    liveData.observe(S_LIFECYCLE_OWNER, mObserver);
    processor.onNext("foo");
    processor.onNext("bar");
    processor.onNext("baz");
    assertThat(mLiveDataOutput, is(Arrays.asList("foo", "bar", "baz")));
}