@Test
public void shouldPropagateErrorsFromConnectable() throws Exception {

  AssertableSubscriber<Integer> subscriber =
      input.compose(RxConnectables.toTransformer(connectable)).test();
  input.onNext("crash");
  subscriber.awaitTerminalEvent(1, TimeUnit.SECONDS);
  subscriber.assertFailureAndMessage(RuntimeException.class, "crashing!");
}