本文整理了Java中org.eclipse.jetty.server.Request.startAsync方法的一些代码示例，展示了Request.startAsync的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Request.startAsync方法的具体详情如下：
包路径：org.eclipse.jetty.server.Request
类名称：Request
方法名：startAsync

Request.startAsync介绍

暂无

代码示例

代码示例来源：origin: apache/nifi

final AsyncContext async = baseRequest.startAsync();
async.setTimeout(requestTimeout);
final boolean added = containerQueue.offer(new HttpRequestContainer(request, response, async));

代码示例来源：origin: AsyncHttpClient/async-http-client

public void handle(String s, Request request, HttpServletRequest req, final HttpServletResponse resp) throws IOException {
  resp.setContentType("text/plain;charset=utf-8");
  resp.setStatus(200);
  final AsyncContext asyncContext = request.startAsync();
  final PrintWriter writer = resp.getWriter();
  executorService.submit(() -> {
    try {
     Thread.sleep(100);
    } catch (InterruptedException e) {
     logger.error("Failed to sleep for 100 ms.", e);
    }
    logger.info("Delivering part1.");
    writer.write("part1");
    writer.flush();
  });
  executorService.submit(() -> {
    try {
     Thread.sleep(200);
    } catch (InterruptedException e) {
     logger.error("Failed to sleep for 200 ms.", e);
    }
    logger.info("Delivering part2.");
    writer.write("part2");
    writer.flush();
    asyncContext.complete();
  });
  request.setHandled(true);
 }
};

代码示例来源：origin: spotify/apollo

@Override
public void handle(
  String target,
  org.eclipse.jetty.server.Request baseRequest,
  HttpServletRequest req,
  HttpServletResponse resp) throws IOException, ServletException {
 final AsyncContext asyncContext = baseRequest.startAsync();
 RequestMetadata metadata = extractMetadata(req);
 AsyncContextOngoingRequest ongoingRequest =
   new AsyncContextOngoingRequest(asApolloRequest(req),
                   asyncContext,
                   logger,
                   metadata);
 asyncContext.setTimeout(requestTimeout.toMillis());
 asyncContext.addListener(TimeoutListener.create(ongoingRequest));
 requestHandler.handle(ongoingRequest);
 baseRequest.setHandled(true);
}

代码示例来源：origin: org.apache.nifi/nifi-standard-processors

final AsyncContext async = baseRequest.startAsync();
async.setTimeout(requestTimeout);
final boolean added = containerQueue.offer(new HttpRequestContainer(request, response, async));

代码示例来源：origin: Valandur/Web-API

AsyncContext ctx = baseRequest.startAsync();
contexts.put(id, ctx);

代码示例来源：origin: jenkinsci/winstone

LOG.debug("Threadlimited {} {}",remote,target);
AsyncContext async = baseRequest.startAsync();

代码示例来源：origin: at.bestsolution.efxclipse.eclipse/org.eclipse.jetty.server

AsyncContext context = baseRequest.startAsync();
baseRequest.setAttribute(AHW_ATTR,ctype);

代码示例来源：origin: jenkinsci/winstone

AsyncContext context = baseRequest.startAsync();
baseRequest.setAttribute(AHW_ATTR,ctype);

代码示例来源：origin: Nextdoor/bender

AsyncContext context = baseRequest.startAsync();
baseRequest.setAttribute(AHW_ATTR,ctype);