@Test
public void customOnErrorShouldReportCustomOnError() {

    LambdaSubscriber<Integer> o = new LambdaSubscriber<Integer>(Functions.<Integer>emptyConsumer(),
            Functions.<Throwable>emptyConsumer(),
            Functions.EMPTY_ACTION,
            FlowableInternalHelper.RequestMax.INSTANCE);
    assertTrue(o.hasCustomOnError());
}