@Test
public void shouldPropagateCompletion() throws Exception {

  TestObserver<Integer> observer =
      input.compose(RxConnectables.toTransformer(connectable)).test();
  input.onNext("hi");
  input.onComplete();
  observer.awaitDone(1, TimeUnit.SECONDS);
  observer.assertComplete();
}