org.eclipse.jetty.client.api.Response.getRequest()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(4.3k)|赞(0)|评价(0)|浏览(75)

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

Response.getRequest介绍

暂无

代码示例

代码示例来源:origin: org.eclipse.jetty/jetty-client

@Override
public Request getRequest()
{
  return response.getRequest();
}

代码示例来源:origin: isucon/isucon5-final

public boolean isContentBodyChecksum(String checksum) {
  if (! contentBodyChecksum.toUpperCase().equals(checksum.toUpperCase())) {
    addViolation(String.format("パス %s のcontent bodyの内容が一致しません", response.getRequest().getPath()));
    return wrap(false);
  }
  return wrap(true);
}

代码示例来源:origin: isucon/isucon5-qualify

public void isContentLength(long bytes) {
 String value = response.getHeaders().get("Content-Length");
 if (value == null) {
  addViolation(String.format("リクエストパス %s に対して Content-Length がありませんでした", response.getRequest().getPath()));
 } else if (Long.parseLong(value) == bytes) {
  // ok
 } else {
  addViolation(String.format("パス %s に対するレスポンスのサイズが正しくありません: %s bytes", response.getRequest().getPath(), value));
 }
}

代码示例来源:origin: isucon/isucon5-qualify

public void isStatus(int status) {
 if (response.getStatus() != status) {
  addViolation(String.format("パス '%s' へのレスポンスコード %d が期待されていましたが %d でした", response.getRequest().getPath(), status, response.getStatus()));
 }
}

代码示例来源:origin: isucon/isucon5-final

public boolean isContentLength(long bytes) {
  String value = response.getHeaders().get("Content-Length");
  if (value == null) {
    addViolation(String.format("リクエストパス %s に対して Content-Length がありませんでした", response.getRequest().getPath()));
    return wrap(false);
  } else if (Long.parseLong(value) == bytes) {
    return wrap(true);
  } else {
    addViolation(String.format("パス %s に対するレスポンスのサイズが正しくありません: %s bytes", response.getRequest().getPath(), value));
    return wrap(false);
  }
}

代码示例来源:origin: org.eclipse.jetty/jetty-client

Request request = response.getRequest();
HttpFields headers = response.getHeaders();
long length = headers.getLongField(HttpHeader.CONTENT_LENGTH.asString());

代码示例来源:origin: isucon/isucon5-final

public boolean isStatus(int status) {
  if (response.getStatus() != status) {
    String msg = "パス '%s' へのレスポンスコード %d が期待されていましたが %d でした";
    addViolation(String.format(msg, response.getRequest().getPath(), status, response.getStatus()));
    return wrap(false);
  }
  return wrap(true);
}

代码示例来源:origin: org.eclipse.jetty/jetty-client

@Override
public void onFailure(Response response, Throwable failure)
{
  HttpConversation conversation = ((HttpRequest)response.getRequest()).getConversation();
  // Mark the 100 Continue response as handled
  conversation.setAttribute(ATTRIBUTE, Boolean.TRUE);
  // Reset the conversation listeners to allow the conversation to be completed
  conversation.updateResponseListeners(null);
  HttpExchange exchange = conversation.getExchanges().peekLast();
  assert exchange.getResponse() == response;
  List<Response.ResponseListener> listeners = exchange.getResponseListeners();
  HttpContentResponse contentResponse = new HttpContentResponse(response, getContent(), getMediaType(), getEncoding());
  notifier.forwardFailureComplete(listeners, exchange.getRequest(), exchange.getRequestFailure(), contentResponse, failure);
}

代码示例来源:origin: org.eclipse.jetty/jetty-client

@Override
public void onSuccess(Response response)
{
  // Handling of success must be done here and not from onComplete(),
  // since the onComplete() is not invoked because the request is not completed yet.
  Request request = response.getRequest();
  HttpConversation conversation = ((HttpRequest)request).getConversation();
  // Mark the 100 Continue response as handled
  request.attribute(ATTRIBUTE, Boolean.TRUE);
  // Reset the conversation listeners, since we are going to receive another response code
  conversation.updateResponseListeners(null);
  HttpExchange exchange = conversation.getExchanges().peekLast();
  if (response.getStatus() == HttpStatus.CONTINUE_100)
  {
    // All good, continue.
    exchange.resetResponse();
    exchange.proceed(null);
    onContinue(request);
  }
  else
  {
    // Server either does not support 100 Continue,
    // or it does and wants to refuse the request content,
    // or we got some other HTTP status code like a redirect.
    List<Response.ResponseListener> listeners = exchange.getResponseListeners();
    HttpContentResponse contentResponse = new HttpContentResponse(response, getContent(), getMediaType(), getEncoding());
    notifier.forwardSuccess(listeners, contentResponse);
    exchange.proceed(new HttpRequestException("Expectation failed", request));
  }
}

相关文章