diff --git a/src/org/redkale/net/http/HttpResponse.java b/src/org/redkale/net/http/HttpResponse.java index 1d6f3c9ff..262645495 100644 --- a/src/org/redkale/net/http/HttpResponse.java +++ b/src/org/redkale/net/http/HttpResponse.java @@ -148,6 +148,10 @@ public class HttpResponse extends Response { return super.removeChannel(); } + protected AsyncConnection getChannel() { + return channel; + } + @Override protected boolean recycle() { boolean rs = super.recycle(); @@ -229,7 +233,7 @@ public class HttpResponse extends Response { return Utility.createAsyncHandler((v, a) -> { finish(v); }, (t, a) -> { - request.getContext().getLogger().log(Level.WARNING, "Servlet occur, forece to close channel. request = " + request + ", result is CompletionHandler", (Throwable)t); + request.getContext().getLogger().log(Level.WARNING, "Servlet occur, forece to close channel. request = " + request + ", result is CompletionHandler", (Throwable) t); finish(500, null); }); } @@ -432,7 +436,7 @@ public class HttpResponse extends Response { } else if (obj instanceof CompletableFuture) { ((CompletableFuture) obj).whenComplete((v, e) -> { if (e != null) { - context.getLogger().log(Level.WARNING, "Servlet occur, forece to close channel. request = " + request + ", result is CompletableFuture", (Throwable)e); + context.getLogger().log(Level.WARNING, "Servlet occur, forece to close channel. request = " + request + ", result is CompletableFuture", (Throwable) e); finish(500, null); return; }