@Test
public void onErrorWithoutOnSubscribe() {

    TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
    SafeSubscriber<Integer> so = new SafeSubscriber<Integer>(ts);
    so.onError(new TestException());
    ts.assertFailure(CompositeException.class);
    TestHelper.assertError(ts, 0, TestException.class);
    TestHelper.assertError(ts, 1, NullPointerException.class, "Subscription not set!");
}