Skip to content

Commit 8742df7

Browse files
author
wuayee
committed
[fit] keep NettyResponse from closing prematurely
1 parent 525f83d commit 8742df7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

framework/fit/java/fit-builtin/plugins/fit-http-server-netty/src/main/java/modelengine/fit/http/server/netty/HttpClassicRequestAssembler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -164,8 +164,8 @@ private void handleHttpRequest(ChannelHandlerContext ctx, HttpRequest request) {
164164
private void doHttpRequest(ChannelHandlerContext ctx, NettyHttpServerRequest request) {
165165
request.setExecuteThread(Thread.currentThread());
166166
try (HttpClassicServerRequest classicRequest = HttpClassicServerRequest.create(this.server, request);
167-
NettyHttpServerResponse response = new NettyHttpServerResponse(ctx, request);
168-
HttpClassicServerResponse classicResponse = HttpClassicServerResponse.create(this.server, response)) {
167+
HttpClassicServerResponse classicResponse = HttpClassicServerResponse.create(this.server,
168+
new NettyHttpServerResponse(ctx, request))) {
169169
HttpHandler handler = this.server.httpDispatcher().dispatch(classicRequest, classicResponse);
170170
classicRequest.attributes().set(PATH_PATTERN.key(), handler.pathPattern());
171171
classicRequest.attributes().set(HTTP_HANDLER.key(), handler);

0 commit comments

Comments
 (0)