io.airlift.http.client.Response.getHeaders()方法的使用及代码示例

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

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

Response.getHeaders介绍

暂无

代码示例

代码示例来源:origin: prestodb/presto

@Override
public ProxyResponse handle(Request request, Response response)
{
  if (response.getStatusCode() == NO_CONTENT.code()) {
    return new ProxyResponse(response.getHeaders(), new byte[0]);
  }
  if (response.getStatusCode() != OK.code()) {
    throw new ProxyException(format("Bad status code from remote Presto server: %s: %s", response.getStatusCode(), readBody(response)));
  }
  String contentType = response.getHeader(CONTENT_TYPE);
  if (contentType == null) {
    throw new ProxyException("No Content-Type set in response from remote Presto server");
  }
  if (!MediaType.parse(contentType).is(MEDIA_TYPE_JSON)) {
    throw new ProxyException("Bad Content-Type from remote Presto server:" + contentType);
  }
  try {
    return new ProxyResponse(response.getHeaders(), toByteArray(response.getInputStream()));
  }
  catch (IOException e) {
    throw new ProxyException("Failed reading response from remote Presto server", e);
  }
}

代码示例来源:origin: airlift/airlift

@Nullable
default String getHeader(String name)
{
  List<String> values = getHeaders(name);
  return values.isEmpty() ? null : values.get(0);
}

代码示例来源:origin: io.airlift/http-client-experimental

@Override
  public ListMultimap<String, String> handle(Request request, Response response)
      throws Exception
  {
    return response.getHeaders();
  }
}

代码示例来源:origin: airlift/airlift

ListMultimap<HeaderName, String> getHeaders();

代码示例来源:origin: airlift/airlift

public UnexpectedResponseException(String message, Request request, Response response)
{
  this(message,
      request,
      response.getStatusCode(),
      response.getStatusMessage(),
      ImmutableListMultimap.copyOf(response.getHeaders()));
}

代码示例来源:origin: com.facebook.presto/presto-raptor

private static StatusResponse createStatusResponse(Response response)
  {
    return new StatusResponse(response.getStatusCode(), response.getStatusMessage(), response.getHeaders());
  }
}

代码示例来源:origin: airlift/airlift

@Override
public StatusResponse handle(Request request, Response response)
{
  return new StatusResponse(response.getStatusCode(), response.getStatusMessage(), response.getHeaders());
}

代码示例来源:origin: prestosql/presto

private static StatusResponse createStatusResponse(Response response)
  {
    return new StatusResponse(response.getStatusCode(), response.getStatusMessage(), response.getHeaders());
  }
}

代码示例来源:origin: airlift/airlift

public UnexpectedResponseException(Request request, Response response)
{
  this(String.format("%d: %s", response.getStatusCode(), response.getStatusMessage()),
      request,
      response.getStatusCode(),
      response.getStatusMessage(),
      ImmutableListMultimap.copyOf(response.getHeaders()));
}

代码示例来源:origin: airlift/airlift

@Override
public StringResponse handle(Request request, Response response)
{
  try {
    String contentType = response.getHeader(CONTENT_TYPE);
    if (contentType != null) {
      MediaType mediaType = MediaType.parse(contentType);
      return new StringResponse(
          response.getStatusCode(),
          response.getStatusMessage(),
          response.getHeaders(),
          new String(ByteStreams.toByteArray(response.getInputStream()), mediaType.charset().or(UTF_8)));
    }
    return new StringResponse(
        response.getStatusCode(),
        response.getStatusMessage(),
        response.getHeaders(),
        new String(ByteStreams.toByteArray(response.getInputStream()), UTF_8));
  }
  catch (IOException e) {
    throw new UncheckedIOException(e);
  }
}

代码示例来源:origin: airlift/airlift

@Override
public JsonResponse<T> handle(Request request, Response response)
{
  byte[] bytes = readResponseBytes(response);
  String contentType = response.getHeader(CONTENT_TYPE);
  if ((contentType == null) || !MediaType.parse(contentType).is(MEDIA_TYPE_JSON)) {
    return new JsonResponse<>(response.getStatusCode(), response.getStatusMessage(), response.getHeaders(), bytes);
  }
  return new JsonResponse<>(response.getStatusCode(), response.getStatusMessage(), response.getHeaders(), jsonCodec, bytes);
}

代码示例来源:origin: airlift/airlift

@Test
public void testResponseHeadersCaseInsensitive()
    throws Exception
{
  URI uri = baseURI.resolve("/road/to/nowhere");
  Request request = prepareGet()
      .setUri(uri)
      .build();
  Response response = executeRequest(request, new PassThroughResponseHandler());
  assertNotNull(response.getHeader("date"));
  assertNotNull(response.getHeader("DATE"));
  assertEquals(response.getHeaders("date").size(), 1);
  assertEquals(response.getHeaders("DATE").size(), 1);
}

代码示例来源:origin: io.airlift/http-client

@Test
public void testResponseHeadersCaseInsensitive()
    throws Exception
{
  URI uri = baseURI.resolve("/road/to/nowhere");
  Request request = prepareGet()
      .setUri(uri)
      .build();
  Response response = executeRequest(request, new PassThroughResponseHandler());
  assertNotNull(response.getHeader("date"));
  assertNotNull(response.getHeader("DATE"));
  assertEquals(response.getHeaders("date").size(), 1);
  assertEquals(response.getHeaders("DATE").size(), 1);
}

代码示例来源:origin: com.teradata.airlift/http-client

@Test
public void testResponseHeadersCaseInsensitive()
    throws Exception
{
  URI uri = baseURI.resolve("/road/to/nowhere");
  Request request = prepareGet()
      .setUri(uri)
      .build();
  Response response = executeRequest(request, new PassThroughResponseHandler());
  assertNotNull(response.getHeader("date"));
  assertNotNull(response.getHeader("DATE"));
  assertEquals(response.getHeaders("date").size(), 1);
  assertEquals(response.getHeaders("DATE").size(), 1);
}

代码示例来源:origin: prestosql/presto

@Override
public ProxyResponse handle(Request request, Response response)
{
  if (response.getStatusCode() == NO_CONTENT.code()) {
    return new ProxyResponse(response.getHeaders(), new byte[0]);
  }
  if (response.getStatusCode() != OK.code()) {
    throw new ProxyException(format("Bad status code from remote Presto server: %s: %s", response.getStatusCode(), readBody(response)));
  }
  String contentType = response.getHeader(CONTENT_TYPE);
  if (contentType == null) {
    throw new ProxyException("No Content-Type set in response from remote Presto server");
  }
  if (!MediaType.parse(contentType).is(MEDIA_TYPE_JSON)) {
    throw new ProxyException("Bad Content-Type from remote Presto server:" + contentType);
  }
  try {
    return new ProxyResponse(response.getHeaders(), toByteArray(response.getInputStream()));
  }
  catch (IOException e) {
    throw new ProxyException("Failed reading response from remote Presto server", e);
  }
}

相关文章