@Test
public void customOnErrorShouldReportCustomOnError() {

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