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

RxNetty.createHttpRequest介绍

暂无

代码示例

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

public static Observable<HttpClientResponse<ByteBuf>> createHttpGet(String uri) {
  return createHttpRequest(HttpClientRequest.createGet(uri));
}

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

public static Observable<HttpClientResponse<ByteBuf>> createHttpDelete(String uri) {
  return createHttpRequest(HttpClientRequest.createDelete(uri));
}

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

public static Observable<HttpClientResponse<ByteBuf>> createHttpGet(String uri) {
  return createHttpRequest(HttpClientRequest.createGet(uri));
}

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

public static Observable<HttpClientResponse<ByteBuf>> createHttpDelete(String uri) {
  return createHttpRequest(HttpClientRequest.createDelete(uri));
}

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

public static Observable<HttpClientResponse<ByteBuf>> createHttpPost(String uri, Observable<ByteBuf> content) {
  return createHttpRequest(HttpClientRequest.createPost(uri).withContentSource(content));
}

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

public static <T> Observable<HttpClientResponse<ByteBuf>> createHttpPost(String uri, Observable<T> content,
                                     ContentTransformer<T> transformer) {
  return createHttpRequest(HttpClientRequest.createPost(uri).withRawContentSource(content, transformer));
}

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

public static <T> Observable<HttpClientResponse<ByteBuf>> createHttpPut(String uri, Observable<T> content,
                                    ContentTransformer<T> transformer) {
  return createHttpRequest(HttpClientRequest.createPut(uri).withRawContentSource(content, transformer));
}

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

public static <T> Observable<HttpClientResponse<ByteBuf>> createHttpPut(String uri, Observable<T> content,
                                    ContentTransformer<T> transformer) {
  return createHttpRequest(HttpClientRequest.createPut(uri).withRawContentSource(content, transformer));
}

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

public static <T> Observable<HttpClientResponse<ByteBuf>> createHttpPost(String uri, Observable<T> content,
                                     ContentTransformer<T> transformer) {
  return createHttpRequest(HttpClientRequest.createPost(uri).withRawContentSource(content, transformer));
}

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

public static Observable<HttpClientResponse<ByteBuf>> createHttpPut(String uri, Observable<ByteBuf> content) {
  return createHttpRequest(HttpClientRequest.createPut(uri).withContentSource(content));
}

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

public static Observable<HttpClientResponse<ByteBuf>> createHttpPut(String uri, Observable<ByteBuf> content) {
  return createHttpRequest(HttpClientRequest.createPut(uri).withContentSource(content));
}

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

public static Observable<HttpClientResponse<ByteBuf>> createHttpPost(String uri, Observable<ByteBuf> content) {
  return createHttpRequest(HttpClientRequest.createPost(uri).withContentSource(content));
}

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

/**
 * The Mesos HTTP Scheduler API will send a redirect to a client if it is not the leader. The client that is
 * constructed during {@link #openStream} is bound to a specific host and port, due to this behavior
 * we "probe" Mesos to try and find out where it's "master" is before we configure the client.
 *
 * This method will attempt to send a simple GET to {@code mesosUri}, however instead of going to the path
 * specified, it will go to {@code /redirect} and construct a uri relative to mesosUri using the host and port
 * returned in the Location header of the response.
 */
@NotNull
private static URI resolveMesosUri(final @NotNull URI mesosUri) {
  final String redirectUri = createRedirectUri(mesosUri);
  LOGGER.info("Probing Mesos server at {}", redirectUri);
  // When sending an individual request (rather than creating a client) RxNetty WILL follow redirects,
  // so here we tell it not to do that for this request by creating the config object below.
  final HttpClient.HttpClientConfig config =
    HttpClient.HttpClientConfig.Builder.fromDefaultConfig()
      .setFollowRedirect(false)
      .build();
  final HttpClientResponse<ByteBuf> redirectResponse =
    RxNetty.createHttpRequest(HttpClientRequest.createGet(redirectUri), config)
      .toBlocking()
      .first();
  return getUriFromRedirectResponse(mesosUri, redirectResponse);
}

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

/**
 * The Mesos HTTP Scheduler API will send a redirect to a client if it is not the leader. The client that is
 * constructed during {@link #openStream} is bound to a specific host and port, due to this behavior
 * we "probe" Mesos to try and find out where it's "master" is before we configure the client.
 *
 * This method will attempt to send a simple GET to {@code mesosUri}, however instead of going to the path
 * specified, it will go to {@code /redirect} and construct a uri relative to mesosUri using the host and port
 * returned in the Location header of the response.
 */
@NotNull
private static URI resolveMesosUri(final @NotNull URI mesosUri) {
  final String redirectUri = createRedirectUri(mesosUri);
  LOGGER.info("Probing Mesos server at {}", redirectUri);
  // When sending an individual request (rather than creating a client) RxNetty WILL follow redirects,
  // so here we tell it not to do that for this request by creating the config object below.
  final HttpClient.HttpClientConfig config =
    HttpClient.HttpClientConfig.Builder.fromDefaultConfig()
      .setFollowRedirect(false)
      .build();
  final HttpClientResponse<ByteBuf> redirectResponse =
    RxNetty.createHttpRequest(HttpClientRequest.createGet(redirectUri), config)
      .toBlocking()
      .first();
  return getUriFromRedirectResponse(mesosUri, redirectResponse);
}