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

RxNetty.newHttpClientBuilder介绍

暂无

代码示例

代码示例来源：origin: io.reactivex/rxnetty

public static HttpClient<ByteBuf, ByteBuf> createHttpClient(String host, int port) {
  return RxNetty.<ByteBuf, ByteBuf>newHttpClientBuilder(host, port).build();
}

代码示例来源：origin: com.netflix.rxnetty/rx-netty

public static HttpClient<ByteBuf, ByteBuf> createHttpClient(String host, int port) {
  return RxNetty.<ByteBuf, ByteBuf>newHttpClientBuilder(host, port).build();
}

代码示例来源：origin: io.reactivex/rxnetty

public static <I, O> HttpClient<I, O> createHttpClient(String host, int port,
                            PipelineConfigurator<HttpClientResponse<O>,
                            HttpClientRequest<I>> configurator) {
  return RxNetty.<I, O>newHttpClientBuilder(host, port).pipelineConfigurator(configurator).build();
}

代码示例来源：origin: com.netflix.rxnetty/rx-netty

public static <I, O> HttpClient<I, O> createHttpClient(String host, int port,
                            PipelineConfigurator<HttpClientResponse<O>,
                            HttpClientRequest<I>> configurator) {
  return RxNetty.<I, O>newHttpClientBuilder(host, port).pipelineConfigurator(configurator).build();
}

代码示例来源：origin: mesosphere/mesos-rxjava

final HttpClient<ByteBuf, ByteBuf> httpClient = RxNetty.<ByteBuf, ByteBuf>newHttpClientBuilder(uri.getHost(), getPort(uri))
  .withName(userAgent.getEntries().get(0).getName())
  .pipelineConfigurator(new HttpClientPipelineConfigurator<>())

代码示例来源：origin: com.mesosphere.mesos.rx.java/mesos-rxjava-client

final HttpClient<ByteBuf, ByteBuf> httpClient = RxNetty.<ByteBuf, ByteBuf>newHttpClientBuilder(uri.getHost(), getPort(uri))
  .withName(userAgent.getEntries().get(0).getName())
  .pipelineConfigurator(new HttpClientPipelineConfigurator<>())

代码示例来源：origin: io.reactivex/rxnetty-contexts

public static <I, O> HttpClientBuilder<I, O> newHttpClientBuilder(String host, int port,
                                 RequestIdProvider provider,
                                 RequestCorrelator correlator) {
  HttpClientBuilder<I, O> builder = RxNetty.newHttpClientBuilder(host, port);
  return builder.pipelineConfigurator(ContextPipelineConfigurators.<I, O>httpClientConfigurator(provider,
                                                 correlator))
         .withChannelFactory(new HttpContextClientChannelFactory<I, O>(builder.getBootstrap(),
                                        correlator,
                                        builder.getEventsSubject()));
}

代码示例来源：origin: com.microsoft.azure/azure-documentdb-rx

private HttpClientBuilder<ByteBuf, ByteBuf> httpClientBuilder() {
  HttpClientBuilder<ByteBuf, ByteBuf> builder = RxNetty
      .<ByteBuf, ByteBuf>newHttpClientBuilder(this.serviceEndpoint.getHost(), this.serviceEndpoint.getPort())
      .withSslEngineFactory(DefaultFactories.trustAll()).withMaxConnections(connectionPolicy.getMaxPoolSize())
      .withIdleConnectionsTimeoutMillis(this.connectionPolicy.getIdleConnectionTimeout() * 1000);
  ClientConfig config = new ClientConfig.Builder()
      .readTimeout(connectionPolicy.getRequestTimeout(), TimeUnit.SECONDS).build();
  return builder.config(config);
}

代码示例来源：origin: io.reactivex/rxnetty-contexts

public static <I, O> HttpClientBuilder<I, O> newHttpClientBuilder(String host, int port,
    RequestIdProvider provider, RequestCorrelator correlator, 
    PipelineConfigurator<HttpClientResponse<O>, HttpClientRequest<I>> httpConfigurator) {
  HttpClientBuilder<I, O> builder = RxNetty.newHttpClientBuilder(host, port);
  return builder.pipelineConfigurator(ContextPipelineConfigurators.httpClientConfigurator(provider,
                                              correlator,
                                              httpConfigurator))
      .withChannelFactory(new HttpContextClientChannelFactory<I, O>(builder.getBootstrap(), correlator,
                                     builder.getEventsSubject()));
}

代码示例来源：origin: com.netflix.iep/iep-rxhttp

RxNetty.<ByteBuf, ByteBuf>newHttpClientBuilder(server.host(), server.port())
  .pipelineConfigurator(pipelineCfg)
  .config(config)