/*
 * Copyright 2014 Red Hat, Inc.
 *
 * Red Hat licenses this file to you under the Apache License, version 2.0
 * (the "License"); you may not use this file except in compliance with the
 * License.  You may obtain a copy of the License at:
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  See the
 * License for the specific language governing permissions and limitations
 * under the License.
 */

package io.vertx.reactivex.ext.web.client;

import io.vertx.reactivex.RxHelper;
import io.vertx.reactivex.ObservableHelper;
import io.vertx.reactivex.FlowableHelper;
import io.vertx.reactivex.impl.AsyncResultMaybe;
import io.vertx.reactivex.impl.AsyncResultSingle;
import io.vertx.reactivex.impl.AsyncResultCompletable;
import io.vertx.reactivex.WriteStreamObserver;
import io.vertx.reactivex.WriteStreamSubscriber;
import java.util.Map;
import java.util.Set;
import java.util.List;
import java.util.Iterator;
import java.util.function.Function;
import java.util.stream.Collectors;
import io.vertx.core.Handler;
import io.vertx.core.AsyncResult;
import io.vertx.core.json.JsonObject;
import io.vertx.core.json.JsonArray;
import io.vertx.lang.rx.RxGen;
import io.vertx.lang.rx.TypeArg;
import io.vertx.lang.rx.MappingIterator;

A client-side HTTP request.
 Instances are created by an WebClient instance, via one of the methods corresponding to the specific HTTP methods such as WebClient.get, etc... 

The request shall be configured prior sending, the request is immutable and when a mutator method
is called, a new request is returned allowing to expose the request in a public API and apply further customization.

After the request has been configured, the methods

  
send
  
sendStream
  
 ()}
  
sendForm

can be called.
The sendXXX methods perform the actual request, they can be called multiple times to perform the same HTTP
request at different points in time.

The handler is called back with

  
an HttpResponse instance when the HTTP response has been received
  
a failure when the HTTP request failed (like a connection error) or when the HTTP response could
  not be obtained (like connection or unmarshalling errors)


Most of the time, this client will buffer the HTTP response fully unless a specific  is used
such as .
 NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen. /**
 * A client-side HTTP request.
 * <p>
 * Instances are created by an {@link io.vertx.reactivex.ext.web.client.WebClient} instance, via one of the methods corresponding to the specific
 * HTTP methods such as {@link io.vertx.reactivex.ext.web.client.WebClient#get}, etc...
 * <p>
 * The request shall be configured prior sending, the request is immutable and when a mutator method
 * is called, a new request is returned allowing to expose the request in a public API and apply further customization.
 * <p>
 * After the request has been configured, the methods
 * <ul>
 *   <li>{@link io.vertx.reactivex.ext.web.client.HttpRequest#send}</li>
 *   <li>{@link io.vertx.reactivex.ext.web.client.HttpRequest#sendStream}</li>
 *   <li> ()}</li>
 *   <li>{@link io.vertx.reactivex.ext.web.client.HttpRequest#sendForm}</li>
 * </ul>
 * can be called.
 * The <code>sendXXX</code> methods perform the actual request, they can be called multiple times to perform the same HTTP
 * request at different points in time.
 * <p>
 * The handler is called back with
 * <ul>
 *   <li>an {@link io.vertx.reactivex.ext.web.client.HttpResponse} instance when the HTTP response has been received</li>
 *   <li>a failure when the HTTP request failed (like a connection error) or when the HTTP response could
 *   not be obtained (like connection or unmarshalling errors)</li>
 * </ul>
 * <p>
 * Most of the time, this client will buffer the HTTP response fully unless a specific  is used
 * such as .
 *
 * <p/>
 * NOTE: This class has been automatically generated from the {@link io.vertx.ext.web.client.HttpRequest original} non RX-ified interface using Vert.x codegen.
 */

@RxGen(io.vertx.ext.web.client.HttpRequest.class)
public class HttpRequest<T> {

  @Override
  public String toString() {
    return delegate.toString();
  }

  @Override
  public boolean equals(Object o) {
    if (this == o) return true;
    if (o == null || getClass() != o.getClass()) return false;
    HttpRequest that = (HttpRequest) o;
    return delegate.equals(that.delegate);
  }
  
  @Override
  public int hashCode() {
    return delegate.hashCode();
  }

  public static final TypeArg<HttpRequest> __TYPE_ARG = new TypeArg<>(    obj -> new HttpRequest((io.vertx.ext.web.client.HttpRequest) obj),
    HttpRequest::getDelegate
  );

  private final io.vertx.ext.web.client.HttpRequest<T> delegate;
  public final TypeArg<T> __typeArg_0;
  
  public HttpRequest(io.vertx.ext.web.client.HttpRequest delegate) {
    this.delegate = delegate;
    this.__typeArg_0 = TypeArg.unknown();  }

  public HttpRequest(Object delegate, TypeArg<T> typeArg_0) {
    this.delegate = (io.vertx.ext.web.client.HttpRequest)delegate;
    this.__typeArg_0 = typeArg_0;
  }

  public io.vertx.ext.web.client.HttpRequest getDelegate() {
    return delegate;
  }


  
Configure the request to use a new method value.
Params:
value – 
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to use a new method <code>value</code>.
   * @param value 
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> method(io.vertx.core.http.HttpMethod value) { 
    delegate.method(value);
    return this;
  }

  
Configure the request to use a new port value.
Params:
value – 
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to use a new port <code>value</code>.
   * @param value 
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> port(int value) { 
    delegate.port(value);
    return this;
  }

  
Configure the request to decode the response with the responseCodec.
Params:
responseCodec – the response codec
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to decode the response with the <code>responseCodec</code>.
   * @param responseCodec the response codec
   * @return a reference to this, so the API can be used fluently
   */
  public <U> io.vertx.reactivex.ext.web.client.HttpRequest<U> as(io.vertx.reactivex.ext.web.codec.BodyCodec<U> responseCodec) { 
    io.vertx.reactivex.ext.web.client.HttpRequest<U> ret = io.vertx.reactivex.ext.web.client.HttpRequest.newInstance((io.vertx.ext.web.client.HttpRequest)delegate.as(responseCodec.getDelegate()), responseCodec.__typeArg_0);
    return ret;
  }

  
Configure the request to use a new host value.
Params:
value – 
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to use a new host <code>value</code>.
   * @param value 
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> host(String value) { 
    delegate.host(value);
    return this;
  }

  
Configure the request to use a virtual host value.

Usually the header host (:authority pseudo header for HTTP/2) is set from the request host value
since this host value resolves to the server IP address.

Sometimes you need to set a host header for an address that does not resolve to the server IP address.
The virtual host value overrides the value of the actual host header (:authority pseudo header
for HTTP/2).

The virtual host is also be used for SNI.
Params:
value – 
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to use a virtual host <code>value</code>.
   * <p/>
   * Usually the header <i>host</i> (<i>:authority</i> pseudo header for HTTP/2) is set from the request host value
   * since this host value resolves to the server IP address.
   * <p/>
   * Sometimes you need to set a host header for an address that does not resolve to the server IP address.
   * The virtual host value overrides the value of the actual <i>host</i> header (<i>:authority</i> pseudo header
   * for HTTP/2).
   * <p/>
   * The virtual host is also be used for SNI.
   * @param value 
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> virtualHost(String value) { 
    delegate.virtualHost(value);
    return this;
  }

  
Configure the request to use a new request URI value.
 When the uri has query parameters, they are set in the queryParams multimap, overwritting any parameters previously set. 
Params:
value – 
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to use a new request URI <code>value</code>.
   * <p>
   * When the uri has query parameters, they are set in the {@link io.vertx.reactivex.ext.web.client.HttpRequest#queryParams} multimap, overwritting
   * any parameters previously set.
   * @param value 
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> uri(String value) { 
    delegate.uri(value);
    return this;
  }

  
Configure the request to add multiple HTTP headers .
Params:
headers – The HTTP headers
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to add multiple HTTP headers .
   * @param headers The HTTP headers
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> putHeaders(io.vertx.reactivex.core.MultiMap headers) { 
    delegate.putHeaders(headers.getDelegate());
    return this;
  }

  
Configure the request to set a new HTTP header.
Params:
name – the header name
value – the header value
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to set a new HTTP header.
   * @param name the header name
   * @param value the header value
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> putHeader(String name, String value) { 
    delegate.putHeader(name, value);
    return this;
  }

  
Returns:
The HTTP headers/**
   * @return The HTTP headers
   */
  public io.vertx.reactivex.core.MultiMap headers() { 
    if (cached_0 != null) {
      return cached_0;
    }
    io.vertx.reactivex.core.MultiMap ret = io.vertx.reactivex.core.MultiMap.newInstance((io.vertx.core.MultiMap)delegate.headers());
    cached_0 = ret;
    return ret;
  }

  
Configure the request to perform basic access authentication.

In basic HTTP authentication, a request contains a header field of the form 'Authorization: Basic <credentials>',
where credentials is the base64 encoding of id and password joined by a colon.

In practical terms the arguments are converted to a  object.
Params:
id – the id
password – the password
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to perform basic access authentication.
   * <p>
   * In basic HTTP authentication, a request contains a header field of the form 'Authorization: Basic &#60;credentials&#62;',
   * where credentials is the base64 encoding of id and password joined by a colon.
   * </p>
   * In practical terms the arguments are converted to a  object.
   * @param id the id
   * @param password the password
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> basicAuthentication(String id, String password) { 
    delegate.basicAuthentication(id, password);
    return this;
  }

  
Configure the request to perform basic access authentication.

In basic HTTP authentication, a request contains a header field of the form 'Authorization: Basic <credentials>',
where credentials is the base64 encoding of id and password joined by a colon.

In practical terms the arguments are converted to a  object.
Params:
id – the id
password – the password
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to perform basic access authentication.
   * <p>
   * In basic HTTP authentication, a request contains a header field of the form 'Authorization: Basic &#60;credentials&#62;',
   * where credentials is the base64 encoding of id and password joined by a colon.
   * </p>
   * In practical terms the arguments are converted to a  object.
   * @param id the id
   * @param password the password
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> basicAuthentication(io.vertx.reactivex.core.buffer.Buffer id, io.vertx.reactivex.core.buffer.Buffer password) { 
    delegate.basicAuthentication(id.getDelegate(), password.getDelegate());
    return this;
  }

  
Configure the request to perform bearer token authentication.

In OAuth 2.0, a request contains a header field of the form 'Authorization: Bearer <bearerToken>',
where bearerToken is the bearer token issued by an authorization server to access protected resources.

In practical terms the arguments are converted to a  object.
Params:
bearerToken – the bearer token
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to perform bearer token authentication.
   * <p>
   * In OAuth 2.0, a request contains a header field of the form 'Authorization: Bearer &#60;bearerToken&#62;',
   * where bearerToken is the bearer token issued by an authorization server to access protected resources.
   * </p>
   * In practical terms the arguments are converted to a  object.
   * @param bearerToken the bearer token
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> bearerTokenAuthentication(String bearerToken) { 
    delegate.bearerTokenAuthentication(bearerToken);
    return this;
  }

  public io.vertx.reactivex.ext.web.client.HttpRequest<T> ssl(Boolean value) { 
    delegate.ssl(value);
    return this;
  }

  
Configures the amount of time in milliseconds after which if the request does not return any data within the timeout period an TimeoutException fails the request. 

Setting zero or a negative value disables the timeout.
Params:
value – The quantity of time in milliseconds.
Returns:
a reference to this, so the API can be used fluently/**
   * Configures the amount of time in milliseconds after which if the request does not return any data within the timeout
   * period an {@link java.util.concurrent.TimeoutException} fails the request.
   * <p>
   * Setting zero or a negative <code>value</code> disables the timeout.
   * @param value The quantity of time in milliseconds.
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> timeout(long value) { 
    delegate.timeout(value);
    return this;
  }

  
Add a query parameter to the request.
Params:
paramName – the param name
paramValue – the param value
Returns:
a reference to this, so the API can be used fluently/**
   * Add a query parameter to the request.
   * @param paramName the param name
   * @param paramValue the param value
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> addQueryParam(String paramName, String paramValue) { 
    delegate.addQueryParam(paramName, paramValue);
    return this;
  }

  
Set a query parameter to the request.
Params:
paramName – the param name
paramValue – the param value
Returns:
a reference to this, so the API can be used fluently/**
   * Set a query parameter to the request.
   * @param paramName the param name
   * @param paramValue the param value
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> setQueryParam(String paramName, String paramValue) { 
    delegate.setQueryParam(paramName, paramValue);
    return this;
  }

  
Set wether or not to follow the directs for the request.
Params:
value – true if redirections should be followed
Returns:
a reference to this, so the API can be used fluently/**
   * Set wether or not to follow the directs for the request.
   * @param value true if redirections should be followed
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> followRedirects(boolean value) { 
    delegate.followRedirects(value);
    return this;
  }

  
Add an expectation that the response is valid according to the provided predicate.

Multiple predicates can be added.
Params:
predicate – the predicate
Returns:
a reference to this, so the API can be used fluently/**
   * Add an expectation that the response is valid according to the provided <code>predicate</code>.
   * <p>
   * Multiple predicates can be added.
   * @param predicate the predicate
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> expect(Function<io.vertx.reactivex.ext.web.client.HttpResponse<Void>, io.vertx.reactivex.ext.web.client.predicate.ResponsePredicateResult> predicate) { 
    delegate.expect(new Function<io.vertx.ext.web.client.HttpResponse<Void>,io.vertx.ext.web.client.predicate.ResponsePredicateResult>() {
      public io.vertx.ext.web.client.predicate.ResponsePredicateResult apply(io.vertx.ext.web.client.HttpResponse<Void> arg) {
        io.vertx.reactivex.ext.web.client.predicate.ResponsePredicateResult ret = predicate.apply(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)arg, TypeArg.unknown()));
        return ret.getDelegate();
      }
    });
    return this;
  }

  
Add an expectation that the response is valid according to the provided predicate.

Multiple predicates can be added.
Params:
predicate – the predicate
Returns:
a reference to this, so the API can be used fluently/**
   * Add an expectation that the response is valid according to the provided <code>predicate</code>.
   * <p>
   * Multiple predicates can be added.
   * @param predicate the predicate
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> expect(io.vertx.reactivex.ext.web.client.predicate.ResponsePredicate predicate) { 
    delegate.expect(predicate.getDelegate());
    return this;
  }

  
Return the current query parameters.
Returns:
the current query parameters/**
   * Return the current query parameters.
   * @return the current query parameters
   */
  public io.vertx.reactivex.core.MultiMap queryParams() { 
    io.vertx.reactivex.core.MultiMap ret = io.vertx.reactivex.core.MultiMap.newInstance((io.vertx.core.MultiMap)delegate.queryParams());
    return ret;
  }

  
Copy this request
Returns:
a copy of this request/**
   * Copy this request
   * @return a copy of this request
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> copy() { 
    io.vertx.reactivex.ext.web.client.HttpRequest<T> ret = io.vertx.reactivex.ext.web.client.HttpRequest.newInstance((io.vertx.ext.web.client.HttpRequest)delegate.copy(), __typeArg_0);
    return ret;
  }

  
Allow or disallow multipart mixed encoding when sending  having files sharing the same
file name.


The default value is true.


Set to false if you want to achieve the behavior for HTML5.
Params:
allow – true allows use of multipart mixed encoding
Returns:
a reference to this, so the API can be used fluently/**
   * Allow or disallow multipart mixed encoding when sending  having files sharing the same
   * file name.
   * <br/>
   * The default value is <code>true</code>.
   * <br/>
   * Set to <code>false</code> if you want to achieve the behavior for <a href="http://www.w3.org/TR/html5/forms.html#multipart-form-data">HTML5</a>.
   * @param allow <code>true</code> allows use of multipart mixed encoding
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> multipartMixed(boolean allow) { 
    io.vertx.reactivex.ext.web.client.HttpRequest<T> ret = io.vertx.reactivex.ext.web.client.HttpRequest.newInstance((io.vertx.ext.web.client.HttpRequest)delegate.multipartMixed(allow), __typeArg_0);
    return ret;
  }

  
Like send but with an HTTP request body stream.
Params:
body – the body
handler – /**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> stream.
   * @param body the body
   * @param handler 
   */
  public void sendStream(io.vertx.reactivex.core.streams.ReadStream<io.vertx.reactivex.core.buffer.Buffer> body, Handler<AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>> handler) { 
    delegate.sendStream(body.getDelegate(), new Handler<AsyncResult<io.vertx.ext.web.client.HttpResponse<T>>>() {
      public void handle(AsyncResult<io.vertx.ext.web.client.HttpResponse<T>> ar) {
        if (ar.succeeded()) {
          handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)ar.result(), __typeArg_0)));
        } else {
          handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
        }
      }
    });
  }

  
Like send but with an HTTP request body stream.
Params:
body – the body/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> stream.
   * @param body the body
   */
  public void sendStream(io.vertx.reactivex.core.streams.ReadStream<io.vertx.reactivex.core.buffer.Buffer> body) {
    sendStream(body, ar -> { });
  }

  
Like send but with an HTTP request body stream.
Params:
body – the body
Returns:
/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> stream.
   * @param body the body
   * @return 
   */
  public io.reactivex.Single<io.vertx.reactivex.ext.web.client.HttpResponse<T>> rxSendStream(io.vertx.reactivex.core.streams.ReadStream<io.vertx.reactivex.core.buffer.Buffer> body) { 
    return AsyncResultSingle.toSingle($handler -> {
      sendStream(body, $handler);
    });
  }

  
Like send but with an HTTP request body stream.
Params:
body – the body
handler – /**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> stream.
   * @param body the body
   * @param handler 
   */
  public void sendStream(io.reactivex.Flowable<io.vertx.reactivex.core.buffer.Buffer> body, Handler<AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>> handler) { 
    delegate.sendStream(io.vertx.reactivex.impl.ReadStreamSubscriber.asReadStream(body, obj -> obj.getDelegate()).resume(), new Handler<AsyncResult<io.vertx.ext.web.client.HttpResponse<T>>>() {
      public void handle(AsyncResult<io.vertx.ext.web.client.HttpResponse<T>> ar) {
        if (ar.succeeded()) {
          handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)ar.result(), __typeArg_0)));
        } else {
          handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
        }
      }
    });
  }

  
Like send but with an HTTP request body stream.
Params:
body – the body/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> stream.
   * @param body the body
   */
  public void sendStream(io.reactivex.Flowable<io.vertx.reactivex.core.buffer.Buffer> body) {
    sendStream(body, ar -> { });
  }

  
Like send but with an HTTP request body stream.
Params:
body – the body
Returns:
/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> stream.
   * @param body the body
   * @return 
   */
  public io.reactivex.Single<io.vertx.reactivex.ext.web.client.HttpResponse<T>> rxSendStream(io.reactivex.Flowable<io.vertx.reactivex.core.buffer.Buffer> body) { 
    return AsyncResultSingle.toSingle($handler -> {
      sendStream(body, $handler);
    });
  }

  
Like send but with an HTTP request body buffer.
Params:
body – the body
handler – /**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> buffer.
   * @param body the body
   * @param handler 
   */
  public void sendBuffer(io.vertx.reactivex.core.buffer.Buffer body, Handler<AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>> handler) { 
    delegate.sendBuffer(body.getDelegate(), new Handler<AsyncResult<io.vertx.ext.web.client.HttpResponse<T>>>() {
      public void handle(AsyncResult<io.vertx.ext.web.client.HttpResponse<T>> ar) {
        if (ar.succeeded()) {
          handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)ar.result(), __typeArg_0)));
        } else {
          handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
        }
      }
    });
  }

  
Like send but with an HTTP request body buffer.
Params:
body – the body/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> buffer.
   * @param body the body
   */
  public void sendBuffer(io.vertx.reactivex.core.buffer.Buffer body) {
    sendBuffer(body, ar -> { });
  }

  
Like send but with an HTTP request body buffer.
Params:
body – the body
Returns:
/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> buffer.
   * @param body the body
   * @return 
   */
  public io.reactivex.Single<io.vertx.reactivex.ext.web.client.HttpResponse<T>> rxSendBuffer(io.vertx.reactivex.core.buffer.Buffer body) { 
    return AsyncResultSingle.toSingle($handler -> {
      sendBuffer(body, $handler);
    });
  }

  
Like send but with an HTTP request body object encoded as json and the content type
set to application/json.
Params:
body – the body
handler – /**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> object encoded as json and the content type
   * set to <code>application/json</code>.
   * @param body the body
   * @param handler 
   */
  public void sendJsonObject(JsonObject body, Handler<AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>> handler) { 
    delegate.sendJsonObject(body, new Handler<AsyncResult<io.vertx.ext.web.client.HttpResponse<T>>>() {
      public void handle(AsyncResult<io.vertx.ext.web.client.HttpResponse<T>> ar) {
        if (ar.succeeded()) {
          handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)ar.result(), __typeArg_0)));
        } else {
          handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
        }
      }
    });
  }

  
Like send but with an HTTP request body object encoded as json and the content type
set to application/json.
Params:
body – the body/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> object encoded as json and the content type
   * set to <code>application/json</code>.
   * @param body the body
   */
  public void sendJsonObject(JsonObject body) {
    sendJsonObject(body, ar -> { });
  }

  
Like send but with an HTTP request body object encoded as json and the content type
set to application/json.
Params:
body – the body
Returns:
/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> object encoded as json and the content type
   * set to <code>application/json</code>.
   * @param body the body
   * @return 
   */
  public io.reactivex.Single<io.vertx.reactivex.ext.web.client.HttpResponse<T>> rxSendJsonObject(JsonObject body) { 
    return AsyncResultSingle.toSingle($handler -> {
      sendJsonObject(body, $handler);
    });
  }

  
Like send but with an HTTP request body object encoded as json and the content type
set to application/json.
Params:
body – the body
handler – /**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> object encoded as json and the content type
   * set to <code>application/json</code>.
   * @param body the body
   * @param handler 
   */
  public void sendJson(java.lang.Object body, Handler<AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>> handler) { 
    delegate.sendJson(body, new Handler<AsyncResult<io.vertx.ext.web.client.HttpResponse<T>>>() {
      public void handle(AsyncResult<io.vertx.ext.web.client.HttpResponse<T>> ar) {
        if (ar.succeeded()) {
          handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)ar.result(), __typeArg_0)));
        } else {
          handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
        }
      }
    });
  }

  
Like send but with an HTTP request body object encoded as json and the content type
set to application/json.
Params:
body – the body/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> object encoded as json and the content type
   * set to <code>application/json</code>.
   * @param body the body
   */
  public void sendJson(java.lang.Object body) {
    sendJson(body, ar -> { });
  }

  
Like send but with an HTTP request body object encoded as json and the content type
set to application/json.
Params:
body – the body
Returns:
/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> object encoded as json and the content type
   * set to <code>application/json</code>.
   * @param body the body
   * @return 
   */
  public io.reactivex.Single<io.vertx.reactivex.ext.web.client.HttpResponse<T>> rxSendJson(java.lang.Object body) { 
    return AsyncResultSingle.toSingle($handler -> {
      sendJson(body, $handler);
    });
  }

  
Like send but with an HTTP request body multimap encoded as form and the content type
set to application/x-www-form-urlencoded.

When the content type header is previously set to multipart/form-data it will be used instead.
Params:
body – the body
handler – /**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> multimap encoded as form and the content type
   * set to <code>application/x-www-form-urlencoded</code>.
   * <p>
   * When the content type header is previously set to <code>multipart/form-data</code> it will be used instead.
   * @param body the body
   * @param handler 
   */
  public void sendForm(io.vertx.reactivex.core.MultiMap body, Handler<AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>> handler) { 
    delegate.sendForm(body.getDelegate(), new Handler<AsyncResult<io.vertx.ext.web.client.HttpResponse<T>>>() {
      public void handle(AsyncResult<io.vertx.ext.web.client.HttpResponse<T>> ar) {
        if (ar.succeeded()) {
          handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)ar.result(), __typeArg_0)));
        } else {
          handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
        }
      }
    });
  }

  
Like send but with an HTTP request body multimap encoded as form and the content type
set to application/x-www-form-urlencoded.

When the content type header is previously set to multipart/form-data it will be used instead.
Params:
body – the body/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> multimap encoded as form and the content type
   * set to <code>application/x-www-form-urlencoded</code>.
   * <p>
   * When the content type header is previously set to <code>multipart/form-data</code> it will be used instead.
   * @param body the body
   */
  public void sendForm(io.vertx.reactivex.core.MultiMap body) {
    sendForm(body, ar -> { });
  }

  
Like send but with an HTTP request body multimap encoded as form and the content type
set to application/x-www-form-urlencoded.

When the content type header is previously set to multipart/form-data it will be used instead.
Params:
body – the body
Returns:
/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> multimap encoded as form and the content type
   * set to <code>application/x-www-form-urlencoded</code>.
   * <p>
   * When the content type header is previously set to <code>multipart/form-data</code> it will be used instead.
   * @param body the body
   * @return 
   */
  public io.reactivex.Single<io.vertx.reactivex.ext.web.client.HttpResponse<T>> rxSendForm(io.vertx.reactivex.core.MultiMap body) { 
    return AsyncResultSingle.toSingle($handler -> {
      sendForm(body, $handler);
    });
  }

  
Like send but with an HTTP request body multimap encoded as form and the content type
set to multipart/form-data. You may use this method to send attributes and upload files.
Params:
body – the body
handler – /**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> multimap encoded as form and the content type
   * set to <code>multipart/form-data</code>. You may use this method to send attributes and upload files.
   * @param body the body
   * @param handler 
   */
  public void sendMultipartForm(io.vertx.reactivex.ext.web.multipart.MultipartForm body, Handler<AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>> handler) { 
    delegate.sendMultipartForm(body.getDelegate(), new Handler<AsyncResult<io.vertx.ext.web.client.HttpResponse<T>>>() {
      public void handle(AsyncResult<io.vertx.ext.web.client.HttpResponse<T>> ar) {
        if (ar.succeeded()) {
          handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)ar.result(), __typeArg_0)));
        } else {
          handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
        }
      }
    });
  }

  
Like send but with an HTTP request body multimap encoded as form and the content type
set to multipart/form-data. You may use this method to send attributes and upload files.
Params:
body – the body/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> multimap encoded as form and the content type
   * set to <code>multipart/form-data</code>. You may use this method to send attributes and upload files.
   * @param body the body
   */
  public void sendMultipartForm(io.vertx.reactivex.ext.web.multipart.MultipartForm body) {
    sendMultipartForm(body, ar -> { });
  }

  
Like send but with an HTTP request body multimap encoded as form and the content type
set to multipart/form-data. You may use this method to send attributes and upload files.
Params:
body – the body
Returns:
/**
   * Like {@link io.vertx.reactivex.ext.web.client.HttpRequest#send} but with an HTTP request <code>body</code> multimap encoded as form and the content type
   * set to <code>multipart/form-data</code>. You may use this method to send attributes and upload files.
   * @param body the body
   * @return 
   */
  public io.reactivex.Single<io.vertx.reactivex.ext.web.client.HttpResponse<T>> rxSendMultipartForm(io.vertx.reactivex.ext.web.multipart.MultipartForm body) { 
    return AsyncResultSingle.toSingle($handler -> {
      sendMultipartForm(body, $handler);
    });
  }

  
Send a request, the handler will receive the response as an HttpResponse. 
Params:
handler – /**
   * Send a request, the <code>handler</code> will receive the response as an {@link io.vertx.reactivex.ext.web.client.HttpResponse}.
   * @param handler 
   */
  public void send(Handler<AsyncResult<io.vertx.reactivex.ext.web.client.HttpResponse<T>>> handler) { 
    delegate.send(new Handler<AsyncResult<io.vertx.ext.web.client.HttpResponse<T>>>() {
      public void handle(AsyncResult<io.vertx.ext.web.client.HttpResponse<T>> ar) {
        if (ar.succeeded()) {
          handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.web.client.HttpResponse.newInstance((io.vertx.ext.web.client.HttpResponse)ar.result(), __typeArg_0)));
        } else {
          handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
        }
      }
    });
  }

  
Send a request, the handler will receive the response as an HttpResponse. /**
   * Send a request, the <code>handler</code> will receive the response as an {@link io.vertx.reactivex.ext.web.client.HttpResponse}.
   */
  public void send() {
    send(ar -> { });
  }

  
Send a request, the handler will receive the response as an HttpResponse. 
Returns:
/**
   * Send a request, the <code>handler</code> will receive the response as an {@link io.vertx.reactivex.ext.web.client.HttpResponse}.
   * @return 
   */
  public io.reactivex.Single<io.vertx.reactivex.ext.web.client.HttpResponse<T>> rxSend() { 
    return AsyncResultSingle.toSingle($handler -> {
      send($handler);
    });
  }

  
Configure the request to set a new HTTP header with multiple values.
Params:
name – the header name
value – the header value
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to set a new HTTP header with multiple values.
   * @param name the header name
   * @param value the header value
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> putHeader(String name, java.lang.Iterable<String> value) { 
    delegate.putHeader(name, value);
    return this;
  }

  
Configure the request to perform HTTP Authentication.

Performs a generic authentication using the credentials provided by the user. For the sake of validation safety
it is recommended that  is called to ensure that the credentials
are applicable to the HTTP Challenged received on a previous request that returned a 401 response code.
Params:
credentials – the credentials to use.
Returns:
a reference to this, so the API can be used fluently/**
   * Configure the request to perform HTTP Authentication.
   * <p>
   * Performs a generic authentication using the credentials provided by the user. For the sake of validation safety
   * it is recommended that  is called to ensure that the credentials
   * are applicable to the HTTP Challenged received on a previous request that returned a 401 response code.
   * @param credentials the credentials to use.
   * @return a reference to this, so the API can be used fluently
   */
  public io.vertx.reactivex.ext.web.client.HttpRequest<T> authentication(io.vertx.ext.auth.authentication.Credentials credentials) { 
    delegate.authentication(credentials);
    return this;
  }

  private io.vertx.reactivex.core.MultiMap cached_0;
  public static <T> HttpRequest<T> newInstance(io.vertx.ext.web.client.HttpRequest arg) {
    return arg != null ? new HttpRequest<T>(arg) : null;
  }

  public static <T> HttpRequest<T> newInstance(io.vertx.ext.web.client.HttpRequest arg, TypeArg<T> __typeArg_T) {
    return arg != null ? new HttpRequest<T>(arg, __typeArg_T) : null;
  }

}