This commit is contained in:
@@ -227,13 +227,7 @@ public class HttpResponse extends Response<HttpContext, HttpRequest> {
|
|||||||
*/
|
*/
|
||||||
public CompletionHandler createAsyncHandler() {
|
public CompletionHandler createAsyncHandler() {
|
||||||
return Utility.createAsyncHandler((v, a) -> {
|
return Utility.createAsyncHandler((v, a) -> {
|
||||||
if (v instanceof org.redkale.service.RetResult) {
|
finish(v);
|
||||||
finishJson((org.redkale.service.RetResult) v);
|
|
||||||
} else if (v instanceof CharSequence) {
|
|
||||||
finish(String.valueOf(v));
|
|
||||||
} else {
|
|
||||||
finishJson(v);
|
|
||||||
}
|
|
||||||
}, (t, a) -> {
|
}, (t, a) -> {
|
||||||
request.getContext().getLogger().log(Level.WARNING, "Servlet occur, forece to close channel. request = " + request, t);
|
request.getContext().getLogger().log(Level.WARNING, "Servlet occur, forece to close channel. request = " + request, t);
|
||||||
finish(500, null);
|
finish(500, null);
|
||||||
|
|||||||
Reference in New Issue
Block a user