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

HttpClient.headersWhen介绍

[英]Apply headers configuration emitted by the returned Mono before requesting.
[中]在请求之前应用由返回的Mono发出的headers配置。

代码示例

代码示例来源：origin: com.rabbitmq/http-client

private Mono<HttpResponse> doDelete(Consumer<? super HttpHeaders> headerBuilder, String... pathSegments) {
  return client.headersWhen(authorizedHeader())
    .headers(headerBuilder)
    .delete()
    .uri(uri(pathSegments))
    .response()
    .doOnNext(applyResponseCallback())
    .map(ReactorNettyClient::toHttpResponse);
}

代码示例来源：origin: rabbitmq/hop

private Mono<HttpResponse> doDelete(Consumer<? super HttpHeaders> headerBuilder, String... pathSegments) {
  return client.headersWhen(authorizedHeader())
    .headers(headerBuilder)
    .delete()
    .uri(uri(pathSegments))
    .response()
    .doOnNext(applyResponseCallback())
    .map(ReactorNettyClient::toHttpResponse);
}

代码示例来源：origin: com.rabbitmq/http-client

private Mono<HttpResponse> doPut(String... pathSegments) {
  return client.headersWhen(authorizedHeader())
    .headers(JSON_HEADER)
    .chunkedTransfer(false)
    .put()
    .uri(uri(pathSegments))
    .response()
    .doOnNext(applyResponseCallback())
    .map(ReactorNettyClient::toHttpResponse);
}

代码示例来源：origin: rabbitmq/hop

private Mono<HttpResponse> doPut(String... pathSegments) {
  return client.headersWhen(authorizedHeader())
    .headers(JSON_HEADER)
    .chunkedTransfer(false)
    .put()
    .uri(uri(pathSegments))
    .response()
    .doOnNext(applyResponseCallback())
    .map(ReactorNettyClient::toHttpResponse);
}

代码示例来源：origin: com.rabbitmq/http-client

private <T> Mono<T> doGetMono(Class<T> type, String... pathSegments) {
  return Mono.from(client
    .headersWhen(authorizedHeader())
    .get()
    .uri(uri(pathSegments))
    .response(decode(type)));
}

代码示例来源：origin: com.rabbitmq/http-client

private Mono<HttpResponse> doPut(Object body, String... pathSegments) {
  return client.headersWhen(authorizedHeader())
    .chunkedTransfer(false)
    .put()
    .uri(uri(pathSegments))
    .send(bodyPublisher(body))
    .response()
    .doOnNext(applyResponseCallback())
    .map(ReactorNettyClient::toHttpResponse);
}

代码示例来源：origin: rabbitmq/hop

private <T> Mono<T> doGetMono(Class<T> type, String... pathSegments) {
  return Mono.from(client
    .headersWhen(authorizedHeader())
    .get()
    .uri(uri(pathSegments))
    .response(decode(type)));
}

代码示例来源：origin: rabbitmq/hop

private Mono<HttpResponse> doPut(Object body, String... pathSegments) {
  return client.headersWhen(authorizedHeader())
    .chunkedTransfer(false)
    .put()
    .uri(uri(pathSegments))
    .send(bodyPublisher(body))
    .response()
    .doOnNext(applyResponseCallback())
    .map(ReactorNettyClient::toHttpResponse);
}

代码示例来源：origin: rabbitmq/hop

private Mono<HttpResponse> doPost(Object body, String... pathSegments) {
  return client.headersWhen(authorizedHeader())
    .headers(JSON_HEADER)
    .chunkedTransfer(false)
    .post()
    .uri(uri(pathSegments))
    .send(bodyPublisher(body))
    .response()
    .doOnNext(applyResponseCallback())
    .map(ReactorNettyClient::toHttpResponse);
}

代码示例来源：origin: com.rabbitmq/http-client

private Mono<HttpResponse> doPost(Object body, String... pathSegments) {
  return client.headersWhen(authorizedHeader())
    .headers(JSON_HEADER)
    .chunkedTransfer(false)
    .post()
    .uri(uri(pathSegments))
    .send(bodyPublisher(body))
    .response()
    .doOnNext(applyResponseCallback())
    .map(ReactorNettyClient::toHttpResponse);
}

代码示例来源：origin: reactor/reactor-netty

@Test
public void testDeferredHeader() {
  DisposableServer context =
      HttpServer.create()
           .host("localhost")
           .route(r -> r.get("/201", (req, res) -> res.addHeader
               ("Content-Length", "0")
                                 .status(HttpResponseStatus.CREATED)
                                 .sendHeaders()))
           .bindNow();
  createHttpClientForContextWithAddress(context)
      .headersWhen(h -> Mono.just(h.set("test", "test")).delayElement(Duration.ofSeconds(2)))
      .observe((c, s) -> System.out.println(s + "" + c))
      .get()
      .uri("/201")
      .responseContent()
      .repeat(4)
      .blockLast();
  context.disposeNow();
}

代码示例来源：origin: reactor/reactor-netty

.port(httpServer.port())
.wiretap(true)
.headersWhen(h -> login(httpServer.port()).map(token -> h.set(
    "Authorization",
    token)))