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

Request.listener介绍

暂无

代码示例

代码示例来源：origin: org.attribyte/attribyte-http

@Override
public ListenableFuture<org.attribyte.api.http.Response> asyncSend(org.attribyte.api.http.Request request, RequestOptions options) {
 final SettableFuture<org.attribyte.api.http.Response> fut = SettableFuture.create();
 final TimingListener listener = new TimingListener(fut, options.maxResponseBytes);
 toJettyRequest(request)
     .followRedirects(options.followRedirects)
     .listener(listener)
     .send(listener);
 return fut;
}

代码示例来源：origin: io.cettia.platform/cettia-platform-test

public Performer send(String uri) {
  HttpClient client = new HttpClient();
  try {
    client.start();
    client.newRequest("http://localhost:" + port + uri).listener(requestListener).send(responseListener);
    latch.await();
  } catch (Exception e) {
    throw new RuntimeException(e);
  } finally {
    try {
      client.stop();
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }
  return this;
}

代码示例来源：origin: org.atmosphere/vibe-platform-test

public Performer send(String uri) {
  HttpClient client = new HttpClient();
  try {
    client.start();
    client.newRequest("http://localhost:" + port + uri).listener(requestListener).send(responseListener);
    latch.await();
  } catch (Exception e) {
    throw new RuntimeException(e);
  } finally {
    try {
      client.stop();
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }
  return this;
}

代码示例来源：origin: org.apache.camel/camel-jetty9

request.followRedirects(supportRedirect).listener(listener).send(responseListener);

代码示例来源：origin: io.github.flowersinthesand/wes-test

public Performer send(String uri, Action<Request> requestAction) {
  HttpClient client = new HttpClient();
  try {
    client.start();
    Request req = client.newRequest("http://localhost:" + port + uri);
    if (requestAction != null) {
      requestAction.on(req);
    }
    req.listener(requestListener).send(responseListener);
    latch.await();
  } catch (Exception e) {
    throw new RuntimeException(e);
  } finally {
    try {
      client.stop();
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }
  return this;
}

代码示例来源：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.cometd.java/cometd-java-client

request.listener(new Request.Listener.Adapter() {
  @Override
  public void onHeaders(Request request) {

代码示例来源：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);
}

代码示例来源：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);
}