@Test
public void shouldPropagateCompletion() throws Exception {

  AssertableSubscriber<Integer> subscriber =
      input.compose(RxConnectables.toTransformer(connectable)).test();
  input.onNext("hi");
  input.onCompleted();
  subscriber.awaitTerminalEvent(1, TimeUnit.SECONDS);
  subscriber.assertCompleted();
}