@Test
public void shouldPropagateErrorsFromConnectable() throws Exception {

  TestObserver<Integer> observer =
      input.compose(RxConnectables.toTransformer(connectable)).test();
  input.onNext("crash");
  observer.awaitDone(1, TimeUnit.SECONDS);
  observer.assertError(throwable -> throwable.getMessage().equals("crashing!"));
}