TestConsumer.kt

abstract class TestConsumer : Consumer<Throwable> {

    lateinit var onError: () -> Unit

    @Throws(Exception::class)
    override fun accept(throwable: Throwable?) {
        throwable?.let {
            if (it is InternetConnectionException) {
                onError()
            } else {
                throw it
            }
        }
    }

}

ViewDelegate.java

 new TestConsumer() {
    @Override
    public void accept(Throwable throwable) throws Exception {
        super.onError = new Function0<Unit>() {
            @Override
            public Unit invoke() {
                mPubOrderDetailsViewDelegate.onError(throwable.getMessage());
                return null;
            }
        };
        super.accept(throwable);
        mPubOrderDetailsViewDelegate.hideProgress();
        if (throwable instanceof OrderNotFoundException) {
            mPubOrderDetailsViewDelegate.onError(mContext.getString(R.string.error_order_not_found, orderId));
        } else {
            mPubOrderDetailsViewDelegate.onError(throwable.getMessage());
        }
        throwable.printStackTrace();
    }
}