本文整理了Java中org.eclipse.jetty.client.api.Request.onComplete
方法的一些代码示例,展示了Request.onComplete
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Request.onComplete
方法的具体详情如下:
包路径:org.eclipse.jetty.client.api.Request
类名称:Request
方法名:onComplete
暂无
代码示例来源:origin: census-instrumentation/opencensus-java
/**
* Returns a new request created from a given {@link URI}.
*
* @param uri {@link URI} to create new request.
* @return {@link Request}
*/
@Override
public Request newRequest(URI uri) {
Request request = super.newRequest(uri);
Request.Listener listener = new HttpRequestListener(tracer.getCurrentSpan(), handler);
request.listener(listener);
request.onComplete((Response.CompleteListener) listener);
request.onResponseContent((Response.ContentListener) listener);
return request;
}
}
代码示例来源:origin: org.eclipse.jetty/jetty-reactive-httpclient
protected ReactiveRequest(Request request) {
this.request = request.listener(requestEvents)
.onResponseBegin(r -> {
synchronized (this) {
this.response = new ReactiveResponse(this, r);
}
})
.onResponseBegin(responseEvents)
.onResponseHeaders(responseEvents)
.onResponseContentAsync(responseEvents)
.onResponseSuccess(responseEvents)
.onResponseFailure(responseEvents)
.onComplete(responseEvents);
}
代码示例来源:origin: jetty-project/jetty-reactive-httpclient
protected ReactiveRequest(Request request) {
this.request = request.listener(requestEvents)
.onResponseBegin(r -> {
synchronized (this) {
this.response = new ReactiveResponse(this, r);
}
})
.onResponseBegin(responseEvents)
.onResponseHeaders(responseEvents)
.onResponseContentAsync(responseEvents)
.onResponseSuccess(responseEvents)
.onResponseFailure(responseEvents)
.onComplete(responseEvents);
}
内容来源于网络,如有侵权,请联系作者删除!