diff options
Diffstat (limited to 'jdisc_http_service')
-rw-r--r-- | jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java index 55b31d6e696..f41e44b0a73 100644 --- a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java +++ b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java @@ -70,7 +70,6 @@ class HttpRequestDispatch { this.async = servletRequest.startAsync(); async.setTimeout(0); - servletResponseController.registerWriteListener(); } public void dispatch() throws IOException { @@ -144,6 +143,7 @@ class HttpRequestDispatch { @SuppressWarnings("try") private ServletRequestReader handleRequest() throws IOException { + servletResponseController.registerWriteListener(); HttpRequest jdiscRequest = HttpRequestFactory.newJDiscRequest(jDiscContext.container, servletRequest); final ContentChannel requestContentChannel; @@ -175,6 +175,7 @@ class HttpRequestDispatch { ContentChannel handleRequestFilterResponse(Response response) { try { + servletResponseController.registerWriteListener(); servletRequest.getInputStream().close(); ContentChannel responseContentChannel = servletResponseController.responseHandler.handleResponse(response); servletResponseController.finishedFuture().whenComplete(completeRequestCallback); |