if (d && act.get() == 0 && empty) {
                        Throwable ex = errors.get();
                        if (ex != null) {
                            a.onError(ExceptionsUtils.terminate(errors));
                        } else {