@Test
public void onNextWithoutOnSubscribe() {

    TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
    SafeSubscriber<Integer> so = new SafeSubscriber<Integer>(ts);
    so.onNext(1);
    ts.assertFailureAndMessage(NullPointerException.class, "Subscription not set!");
}