okhttp3.Response.receivedResponseAtMillis()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(10.2k)|赞(0)|评价(0)|浏览(126)

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

Response.receivedResponseAtMillis介绍

[英]Returns a System#currentTimeMillis() taken immediately after OkHttp received this response's headers from the network. If this response is being served from the cache then this is the timestamp of the original response.
[中]返回一个系统#currentTimeMillis(),该系统在OkHttp从网络收到此响应的头后立即获取。如果此响应是从缓存提供的,则这是原始响应的时间戳。

代码示例

代码示例来源:origin: square/okhttp

Entry(Response response) {
 this.url = response.request().url().toString();
 this.varyHeaders = HttpHeaders.varyHeaders(response);
 this.requestMethod = response.request().method();
 this.protocol = response.protocol();
 this.code = response.code();
 this.message = response.message();
 this.responseHeaders = response.headers();
 this.handshake = response.handshake();
 this.sentRequestMillis = response.sentRequestAtMillis();
 this.receivedResponseMillis = response.receivedResponseAtMillis();
}

代码示例来源:origin: square/okhttp

private static Headers withSyntheticHeaders(Response okResponse) {
 return okResponse.headers().newBuilder()
   .add(SENT_MILLIS, Long.toString(okResponse.sentRequestAtMillis()))
   .add(RECEIVED_MILLIS, Long.toString(okResponse.receivedResponseAtMillis()))
   .build();
}

代码示例来源:origin: com.squareup.okhttp3/okhttp

Entry(Response response) {
 this.url = response.request().url().toString();
 this.varyHeaders = HttpHeaders.varyHeaders(response);
 this.requestMethod = response.request().method();
 this.protocol = response.protocol();
 this.code = response.code();
 this.message = response.message();
 this.responseHeaders = response.headers();
 this.handshake = response.handshake();
 this.sentRequestMillis = response.sentRequestAtMillis();
 this.receivedResponseMillis = response.receivedResponseAtMillis();
}

代码示例来源:origin: apollographql/apollo-android

ResponseHeaderRecord(Response response) {
 this.url = response.request().url().toString();
 this.varyHeaders = HttpHeaders.varyHeaders(response);
 this.requestMethod = response.request().method();
 this.protocol = response.protocol();
 this.code = response.code();
 this.message = response.message();
 this.responseHeaders = response.headers();
 this.handshake = response.handshake();
 this.sentRequestMillis = response.sentRequestAtMillis();
 this.receivedResponseMillis = response.receivedResponseAtMillis();
}

代码示例来源:origin: square/okhttp

public Factory(long nowMillis, Request request, Response cacheResponse) {
 this.nowMillis = nowMillis;
 this.request = request;
 this.cacheResponse = cacheResponse;
 if (cacheResponse != null) {
  this.sentRequestMillis = cacheResponse.sentRequestAtMillis();
  this.receivedResponseMillis = cacheResponse.receivedResponseAtMillis();
  Headers headers = cacheResponse.headers();
  for (int i = 0, size = headers.size(); i < size; i++) {
   String fieldName = headers.name(i);
   String value = headers.value(i);
   if ("Date".equalsIgnoreCase(fieldName)) {
    servedDate = HttpDate.parse(value);
    servedDateString = value;
   } else if ("Expires".equalsIgnoreCase(fieldName)) {
    expires = HttpDate.parse(value);
   } else if ("Last-Modified".equalsIgnoreCase(fieldName)) {
    lastModified = HttpDate.parse(value);
    lastModifiedString = value;
   } else if ("ETag".equalsIgnoreCase(fieldName)) {
    etag = value;
   } else if ("Age".equalsIgnoreCase(fieldName)) {
    ageSeconds = HttpHeaders.parseSeconds(value, -1);
   }
  }
 }
}

代码示例来源:origin: com.squareup.okhttp3/okhttp

public Factory(long nowMillis, Request request, Response cacheResponse) {
 this.nowMillis = nowMillis;
 this.request = request;
 this.cacheResponse = cacheResponse;
 if (cacheResponse != null) {
  this.sentRequestMillis = cacheResponse.sentRequestAtMillis();
  this.receivedResponseMillis = cacheResponse.receivedResponseAtMillis();
  Headers headers = cacheResponse.headers();
  for (int i = 0, size = headers.size(); i < size; i++) {
   String fieldName = headers.name(i);
   String value = headers.value(i);
   if ("Date".equalsIgnoreCase(fieldName)) {
    servedDate = HttpDate.parse(value);
    servedDateString = value;
   } else if ("Expires".equalsIgnoreCase(fieldName)) {
    expires = HttpDate.parse(value);
   } else if ("Last-Modified".equalsIgnoreCase(fieldName)) {
    lastModified = HttpDate.parse(value);
    lastModifiedString = value;
   } else if ("ETag".equalsIgnoreCase(fieldName)) {
    etag = value;
   } else if ("Age".equalsIgnoreCase(fieldName)) {
    ageSeconds = HttpHeaders.parseSeconds(value, -1);
   }
  }
 }
}

代码示例来源:origin: square/okhttp

.headers(combine(cacheResponse.headers(), networkResponse.headers()))
.sentRequestAtMillis(networkResponse.sentRequestAtMillis())
.receivedResponseAtMillis(networkResponse.receivedResponseAtMillis())
.cacheResponse(stripBody(cacheResponse))
.networkResponse(stripBody(networkResponse))

代码示例来源:origin: com.squareup.okhttp3/okhttp

.headers(combine(cacheResponse.headers(), networkResponse.headers()))
.sentRequestAtMillis(networkResponse.sentRequestAtMillis())
.receivedResponseAtMillis(networkResponse.receivedResponseAtMillis())
.cacheResponse(stripBody(cacheResponse))
.networkResponse(stripBody(networkResponse))

代码示例来源:origin: rakam-io/rakam

public Response send() {
  requestBuilder.url(url);
  if (formParams != null) {
    requestBuilder.method(method, formParams.build());
  }
  try {
    Call call = asyncHttpClient.newCall(requestBuilder.build());
    okhttp3.Response response = call.execute();
    LOGGER.debug("Performed request to %s in %dms", url, response.receivedResponseAtMillis() - response.sentRequestAtMillis());
    return new SuccessResponse(response);
  } catch (IOException e) {
    return new ExceptionResponse(e);
  }
}

代码示例来源:origin: rakam-io/rakam

.withMetricData(new MetricDatum()
    .withMetricName("request-latency")
    .withValue(Double.valueOf(execute.receivedResponseAtMillis() - execute.sentRequestAtMillis()))));

代码示例来源:origin: com.github.ljun20160606/okhttp

Entry(Response response) {
 this.url = response.request().url().toString();
 this.varyHeaders = HttpHeaders.varyHeaders(response);
 this.requestMethod = response.request().method();
 this.protocol = response.protocol();
 this.code = response.code();
 this.message = response.message();
 this.responseHeaders = response.headers();
 this.handshake = response.handshake();
 this.sentRequestMillis = response.sentRequestAtMillis();
 this.receivedResponseMillis = response.receivedResponseAtMillis();
}

代码示例来源:origin: apache/servicemix-bundles

Entry(Response response) {
 this.url = response.request().url().toString();
 this.varyHeaders = HttpHeaders.varyHeaders(response);
 this.requestMethod = response.request().method();
 this.protocol = response.protocol();
 this.code = response.code();
 this.message = response.message();
 this.responseHeaders = response.headers();
 this.handshake = response.handshake();
 this.sentRequestMillis = response.sentRequestAtMillis();
 this.receivedResponseMillis = response.receivedResponseAtMillis();
}

代码示例来源:origin: com.pubnub/pubnub-gson

private void storeRequestLatency(Response response, PNOperationType type) {
  if (this.telemetryManager != null) {
    long latency = response.raw().receivedResponseAtMillis() - response.raw().sentRequestAtMillis();
    this.telemetryManager.storeLatency(latency, type);
  }
}

代码示例来源:origin: com.squareup.okhttp3/okhttp-android-support

private static Headers withSyntheticHeaders(Response okResponse) {
 return okResponse.headers().newBuilder()
   .add(SENT_MILLIS, Long.toString(okResponse.sentRequestAtMillis()))
   .add(RECEIVED_MILLIS, Long.toString(okResponse.receivedResponseAtMillis()))
   .build();
}

代码示例来源:origin: com.github.ljun20160606/okhttp

public Factory(long nowMillis, Request request, Response cacheResponse) {
 this.nowMillis = nowMillis;
 this.request = request;
 this.cacheResponse = cacheResponse;
 if (cacheResponse != null) {
  this.sentRequestMillis = cacheResponse.sentRequestAtMillis();
  this.receivedResponseMillis = cacheResponse.receivedResponseAtMillis();
  Headers headers = cacheResponse.headers();
  for (int i = 0, size = headers.size(); i < size; i++) {
   String fieldName = headers.name(i);
   String value = headers.value(i);
   if ("Date".equalsIgnoreCase(fieldName)) {
    servedDate = HttpDate.parse(value);
    servedDateString = value;
   } else if ("Expires".equalsIgnoreCase(fieldName)) {
    expires = HttpDate.parse(value);
   } else if ("Last-Modified".equalsIgnoreCase(fieldName)) {
    lastModified = HttpDate.parse(value);
    lastModifiedString = value;
   } else if ("ETag".equalsIgnoreCase(fieldName)) {
    etag = value;
   } else if ("Age".equalsIgnoreCase(fieldName)) {
    ageSeconds = HttpHeaders.parseSeconds(value, -1);
   }
  }
 }
}

代码示例来源:origin: apache/servicemix-bundles

public Factory(long nowMillis, Request request, Response cacheResponse) {
 this.nowMillis = nowMillis;
 this.request = request;
 this.cacheResponse = cacheResponse;
 if (cacheResponse != null) {
  this.sentRequestMillis = cacheResponse.sentRequestAtMillis();
  this.receivedResponseMillis = cacheResponse.receivedResponseAtMillis();
  Headers headers = cacheResponse.headers();
  for (int i = 0, size = headers.size(); i < size; i++) {
   String fieldName = headers.name(i);
   String value = headers.value(i);
   if ("Date".equalsIgnoreCase(fieldName)) {
    servedDate = HttpDate.parse(value);
    servedDateString = value;
   } else if ("Expires".equalsIgnoreCase(fieldName)) {
    expires = HttpDate.parse(value);
   } else if ("Last-Modified".equalsIgnoreCase(fieldName)) {
    lastModified = HttpDate.parse(value);
    lastModifiedString = value;
   } else if ("ETag".equalsIgnoreCase(fieldName)) {
    etag = value;
   } else if ("Age".equalsIgnoreCase(fieldName)) {
    ageSeconds = HttpHeaders.parseSeconds(value, -1);
   }
  }
 }
}

代码示例来源:origin: jakehilborn/speedr

overpassServer.addLatency(response.receivedResponseAtMillis() - response.sentRequestAtMillis());
} else {
  overpassServer.setDelay(System.nanoTime() + UnitUtils.secondsToNanos(60)); //Don't retry this server for 60 seconds

代码示例来源:origin: ViDA-NYU/ache

ResponseBody body = response.peekBody(targetLength);
  content = body.bytes();
  long totalReadTime = Math.max(1,response.receivedResponseAtMillis() - response.sentRequestAtMillis());
  readRate = (content.length * 1000L) / totalReadTime;
} catch (IOException e) {

代码示例来源:origin: com.github.ljun20160606/okhttp

.headers(combine(cacheResponse.headers(), networkResponse.headers()))
.sentRequestAtMillis(networkResponse.sentRequestAtMillis())
.receivedResponseAtMillis(networkResponse.receivedResponseAtMillis())
.cacheResponse(stripBody(cacheResponse))
.networkResponse(stripBody(networkResponse))

代码示例来源:origin: apache/servicemix-bundles

.headers(combine(cacheResponse.headers(), networkResponse.headers()))
.sentRequestAtMillis(networkResponse.sentRequestAtMillis())
.receivedResponseAtMillis(networkResponse.receivedResponseAtMillis())
.cacheResponse(stripBody(cacheResponse))
.networkResponse(stripBody(networkResponse))

相关文章