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

RxNetty.newHttpServerBuilder介绍

暂无

代码示例

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

public static HttpServer<ByteBuf, ByteBuf> createHttpServer(int port, RequestHandler<ByteBuf, ByteBuf> requestHandler) {
  return newHttpServerBuilder(port, requestHandler).build();
}

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

public static HttpServer<ByteBuf, ByteBuf> createHttpServer(int port, RequestHandler<ByteBuf, ByteBuf> requestHandler) {
  return newHttpServerBuilder(port, requestHandler).build();
}

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

public static <I, O> HttpServer<I, O> createHttpServer(int port,
                            RequestHandler<I, O> requestHandler,
                            PipelineConfigurator<HttpServerRequest<I>, HttpServerResponse<O>> configurator) {
  return newHttpServerBuilder(port, requestHandler).pipelineConfigurator(configurator).build();
}

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

public static <I, O> HttpServerBuilder<I, O> newHttpServerBuilder(int port, RequestHandler<I, O> requestHandler,
                                 RequestIdProvider provider,
                                 RequestCorrelator correlator, 
                                 PipelineConfigurator<HttpServerRequest<I>, HttpServerResponse<O>> configurator) {
  return RxNetty.newHttpServerBuilder(port, requestHandler)
         .pipelineConfigurator(ContextPipelineConfigurators.<I, O>httpServerConfigurator(provider,
                                                 correlator, configurator));
}

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

public static <I, O> HttpServerBuilder<I, O> newHttpServerBuilder(int port, RequestHandler<I, O> requestHandler,
    RequestIdProvider provider,
    RequestCorrelator correlator) {
  return RxNetty.newHttpServerBuilder(port, requestHandler)
      .pipelineConfigurator(ContextPipelineConfigurators.<I, O>httpServerConfigurator(provider,
          correlator));
}

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

public static <I, O> HttpServer<I, O> createHttpServer(int port,
                            RequestHandler<I, O> requestHandler,
                            PipelineConfigurator<HttpServerRequest<I>, HttpServerResponse<O>> configurator) {
  return newHttpServerBuilder(port, requestHandler).pipelineConfigurator(configurator).build();
}

代码示例来源：origin: com.netflix.eureka/eureka2-server

public <I, O> void connectHttpEndpoint(String pathPrefix, RequestHandler<I, O> handler) {
    HttpServer<I, O> backend = RxNetty.newHttpServerBuilder(0, handler).build();
    backend.start();
    backendServers.add(backend);
    proxy.register(ForwardingRule.pathPrefix(backend.getServerPort(), pathPrefix));
    logger.info("Started backend HTTP server on port {} or {}", backend.getServerPort(), handler.getClass().getSimpleName());
  }
}

代码示例来源：origin: com.netflix.karyon/karyon3-rxnetty

@Provides
@Singleton
@ShutdownServer
HttpServer<ByteBuf, ByteBuf> getShutdownServer(@ShutdownServer ServerConfig config, final LifecycleShutdownSignal shutdown) {
  return RxNetty.newHttpServerBuilder(
    config.getServerPort(), 
    new RequestHandler<ByteBuf, ByteBuf>() {
      @Override
      public Observable<Void> handle(
          HttpServerRequest<ByteBuf> request,
          HttpServerResponse<ByteBuf> response) {
        shutdown.signal();
        return response.writeStringAndFlush("Shutting down");
      }
    })
    .build();
}

代码示例来源：origin: com.netflix.eureka2/eureka-test-utils

public MockHttpRxServer<I, O> start() {
  server = RxNetty.newHttpServerBuilder(0, new RequestHandler<ByteBuf, ByteBuf>() {
    @Override
    public Observable<Void> handle(final HttpServerRequest<ByteBuf> request, final HttpServerResponse<ByteBuf> response) {