@Test
public void customOnErrorShouldReportCustomOnError() {

    CallbackCompletableObserver o = new CallbackCompletableObserver(Functions.<Throwable>emptyConsumer(),
            Functions.EMPTY_ACTION);
    assertTrue(o.hasCustomOnError());
}