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