@Test
public void onCompleteWithoutOnSubscribe() {

    TestObserver<Integer> to = new TestObserver<Integer>();
    SafeObserver<Integer> so = new SafeObserver<Integer>(to);
    so.onComplete();
    to.assertFailureAndMessage(NullPointerException.class, "Subscription not set!");
}