in server/src/main/java/org/apache/asyncweb/server/pipeline/StandardRequestPipeline.java [103:121]
private void releaseRequests() {
for (Iterator<Map.Entry<HttpServiceContext, HttpResponse>> iter = entryMap
.entrySet().iterator(); iter.hasNext();) {
Map.Entry<HttpServiceContext, HttpResponse> entry = iter.next();
HttpResponse response = entry.getValue();
if (response != null) {
if (LOG.isDebugEnabled()) {
LOG.debug("Response freed from pipeline. Notifying");
}
listener.responseReleased(entry.getKey());
iter.remove();
} else {
break;
}
}
if (emptyCommand != null && entryMap.isEmpty()) {
emptyCommand.run();
}
}