@Test
public void onErrorFailure() {

    try {
        OBSERVER_ONERROR_FAIL().onError(new SafeSubscriberTestException("error!"));
        fail("expects exception to be thrown");
    } catch (Exception e) {
        assertTrue(e instanceof SafeSubscriberTestException);
        assertEquals("onErrorFail", e.getMessage());
    }
}