@Test
public void noErrorLoss() {

    List<Throwable> errors = TestHelper.trackPluginErrors();
    try {
        ConnectableFlowable<Object> cf = Flowable.error(new TestException()).publish();
        cf.connect();
        TestHelper.assertUndeliverable(errors, 0, TestException.class);
    } finally {
        RxJavaPlugins.reset();
    }
}