本文整理了Java中org.eclipse.jetty.server.Request.setAsyncSupported
方法的一些代码示例,展示了Request.setAsyncSupported
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Request.setAsyncSupported
方法的具体详情如下:
包路径:org.eclipse.jetty.server.Request
类名称:Request
方法名:setAsyncSupported
暂无
代码示例来源:origin: dropwizard/dropwizard
@Override
public void handle(Request baseRequest,
ServletRequest request,
ServletResponse response) throws ServletException, IOException {
final boolean asyncSupported = baseRequest.isAsyncSupported();
if (!isAsyncSupported()) {
baseRequest.setAsyncSupported(false, null);
}
try {
servlet.service(request, response);
} catch (EofException ignored) {
// Want to ignore the EofException as this signifies the client has disconnected or the
// response has already been written. The problem with using an ExceptionMapper is that
// we don't actually want to write a response given that the connection has already been
// closed
} finally {
baseRequest.setAsyncSupported(asyncSupported, null);
}
}
}
代码示例来源:origin: line/armeria
private static void fillRequest(
ServiceRequestContext ctx, AggregatedHttpMessage aReq, Request jReq) {
jReq.setDispatcherType(DispatcherType.REQUEST);
jReq.setAsyncSupported(false, "armeria");
jReq.setSecure(ctx.sessionProtocol().isTls());
jReq.setMetaData(toRequestMetadata(ctx, aReq));
final HttpData content = aReq.content();
if (!content.isEmpty()) {
jReq.getHttpInput().addContent(new Content(ByteBuffer.wrap(
content.array(), content.offset(), content.length())));
}
jReq.getHttpInput().eof();
}
代码示例来源:origin: io.dropwizard/dropwizard-jetty
@Override
public void handle(Request baseRequest,
ServletRequest request,
ServletResponse response) throws ServletException, IOException {
final boolean asyncSupported = baseRequest.isAsyncSupported();
if (!isAsyncSupported()) {
baseRequest.setAsyncSupported(false, null);
}
try {
servlet.service(request, response);
} finally {
baseRequest.setAsyncSupported(asyncSupported, null);
}
}
}
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-all-server
baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, _next);
baseRequest.setAsyncSupported(true);
代码示例来源:origin: jenkinsci/winstone
_baseRequest.setAsyncSupported(false,holder.toString());
filter.doFilter(request, response, this);
_baseRequest.setAsyncSupported(true,null);
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-plus
baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, _next);
baseRequest.setAsyncSupported(true);
代码示例来源:origin: jenkinsci/winstone
baseRequest.setAsyncSupported(false,_filterHolder.toString());
filter.doFilter(request, response, _next);
baseRequest.setAsyncSupported(true,null);
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-webapp
baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, _next);
baseRequest.setAsyncSupported(true);
代码示例来源:origin: at.bestsolution.efxclipse.eclipse/org.eclipse.jetty.servlet
_baseRequest.setAsyncSupported(false,holder.toString());
filter.doFilter(request, response, this);
_baseRequest.setAsyncSupported(true,null);
代码示例来源:origin: com.ovea.tajin.server/tajin-server-jetty9
baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, _next);
baseRequest.setAsyncSupported(true);
代码示例来源:origin: com.ovea.tajin.servers/tajin-server-jetty9
baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, _next);
baseRequest.setAsyncSupported(true);
代码示例来源:origin: Nextdoor/bender
_baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, this);
_baseRequest.setAsyncSupported(requestAsyncSupported);
代码示例来源:origin: com.ovea.tajin.server/tajin-server-jetty9
_baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, this);
_baseRequest.setAsyncSupported(true);
代码示例来源:origin: com.ovea.tajin.servers/tajin-server-jetty9
_baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, this);
_baseRequest.setAsyncSupported(true);
代码示例来源:origin: at.bestsolution.efxclipse.eclipse/org.eclipse.jetty.servlet
baseRequest.setAsyncSupported(false,_filterHolder.toString());
filter.doFilter(request, response, _next);
baseRequest.setAsyncSupported(true,null);
代码示例来源:origin: Nextdoor/bender
baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, _next);
baseRequest.setAsyncSupported(requestAsyncSupported);
代码示例来源:origin: Nextdoor/bender
baseRequest.setAsyncSupported(false);
baseRequest.setAsyncSupported(suspendable);
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-all-server
_baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, this);
_baseRequest.setAsyncSupported(true);
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-webapp
_baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, this);
_baseRequest.setAsyncSupported(true);
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-plus
_baseRequest.setAsyncSupported(false);
filter.doFilter(request, response, this);
_baseRequest.setAsyncSupported(true);
内容来源于网络,如有侵权,请联系作者删除!