@Test
public void shouldPropagateErrorsFromUpstream() throws Exception {

  final Throwable expected = new RuntimeException("expected");
  AssertableSubscriber<Integer> subscriber =
      input.compose(RxConnectables.toTransformer(connectable)).test();
  input.onError(expected);
  subscriber.awaitTerminalEvent(1, TimeUnit.SECONDS);
  subscriber.assertError(expected);
}