@Test
public void onCompleteFailure() {

    AtomicReference<Throwable> onError = new AtomicReference<Throwable>();
    try {
        OBSERVER_ONCOMPLETED_FAIL(onError).onComplete();
        fail("expects exception to be thrown");
    } catch (Exception e) {
        assertNull(onError.get());
        assertTrue(e instanceof SafeObserverTestException);
        assertEquals("onCompleteFail", e.getMessage());
    }
}