Package io.vertx.reactivex.core.http

## Class HttpClientConnection

- java.lang.Object
- - io.vertx.reactivex.core.http.HttpConnection
  - - io.vertx.reactivex.core.http.HttpClientConnection

- All Implemented Interfaces:
    `HttpClient`

      public class HttpClientConnection
      extends HttpConnection
      implements HttpClient

  Represents an HTTP client connection.

  You can use this connection to create requests to the connected server.

  Depending on the nature of the connection, requests might just be sent to the server or might be queued until a connection request is available.

  NOTE: This class has been automatically generated from the `original` non RX-ified interface using Vert.x codegen.

- - ### Field Summary

    Fields
    Modifier and Type | Field | Description
    --- | --- | ---
    `static io.vertx.lang.rx.TypeArg<HttpClientConnection>` | `__TYPE_ARG` |

  - ### Constructor Summary

    Constructors
    Constructor | Description
    --- | ---
    `HttpClientConnection​(HttpClientConnection delegate)` |
    `HttpClientConnection​(Object delegate)` |

  - ### Method Summary

    All Methods Static Methods Instance Methods Concrete Methods
    Modifier and Type | Method | Description
    --- | --- | ---
    `long` | `activeStreams()` |
    `Future<Void>` | `close()` | Close immediately (`shutdown(0, TimeUnit.SECONDS`).
    `boolean` | `equals​(Object o)` |
    `HttpClientConnection` | `getDelegate()` |
    `int` | `hashCode()` |
    `long` | `maxActiveStreams()` |
    `static HttpClientConnection` | `newInstance​(HttpClientConnection arg)` |
    `Future<HttpClientRequest>` | `request()` | Create an HTTP request to send to the server with the default host and port of the client.
    `Future<HttpClientRequest>` | `request​(HttpMethod method, int port, String host, String requestURI)` | Create an HTTP request to send to the server at the `host` and `port`.
    `Future<HttpClientRequest>` | `request​(HttpMethod method, String requestURI)` | Create an HTTP request to send to the server at the default host and port.
    `Future<HttpClientRequest>` | `request​(HttpMethod method, String host, String requestURI)` | Create an HTTP request to send to the server at the `host` and default port.
    `Future<HttpClientRequest>` | `request​(RequestOptions options)` | Create an HTTP request to send to the server.
    `Completable` | `rxClose()` | Close immediately (`shutdown(0, TimeUnit.SECONDS`).
    `Single<HttpClientRequest>` | `rxRequest()` | Create an HTTP request to send to the server with the default host and port of the client.
    `Single<HttpClientRequest>` | `rxRequest​(HttpMethod method, int port, String host, String requestURI)` | Create an HTTP request to send to the server at the `host` and `port`.
    `Single<HttpClientRequest>` | `rxRequest​(HttpMethod method, String requestURI)` | Create an HTTP request to send to the server at the default host and port.
    `Single<HttpClientRequest>` | `rxRequest​(HttpMethod method, String host, String requestURI)` | Create an HTTP request to send to the server at the `host` and default port.
    `Single<HttpClientRequest>` | `rxRequest​(RequestOptions options)` | Create an HTTP request to send to the server.
    `Completable` | `rxShutdown()` | Shutdown with a 30 seconds timeout (`shutdown(30, TimeUnit.SECONDS)`).
    `Completable` | `rxShutdown​(long timeout, TimeUnit unit)` | Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight requests are processed, otherwise after a `timeout` the connection will be closed.
    `Future<Void>` | `shutdown()` | Shutdown with a 30 seconds timeout (`shutdown(30, TimeUnit.SECONDS)`).
    `Future<Void>` | `shutdown​(long timeout, TimeUnit unit)` | Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight requests are processed, otherwise after a `timeout` the connection will be closed.
    `String` | `toString()` |

    - ### Methods inherited from class io.vertx.reactivex.core.http.HttpConnection

      `closeHandler, exceptionHandler, getWindowSize, goAway, goAway, goAway, goAwayHandler, indicatedServerName, isSsl, localAddress, localAddress, newInstance, ping, pingHandler, remoteAddress, remoteAddress, remoteSettings, remoteSettingsHandler, rxPing, rxUpdateSettings, settings, setWindowSize, shutdownHandler, sslSession, updateSettings`

    - ### Methods inherited from class java.lang.Object

      `clone, finalize, getClass, notify, notifyAll, wait, wait, wait`

- - ### Field Detail

    - #### __TYPE_ARG

          public static final io.vertx.lang.rx.TypeArg<HttpClientConnection> __TYPE_ARG

  - ### Constructor Detail

    - #### HttpClientConnection

          public HttpClientConnection​(HttpClientConnection delegate)

    - #### HttpClientConnection

          public HttpClientConnection​(Object delegate)

  - ### Method Detail

    - #### toString

          public String toString()

      Overrides:
        `toString` in class `HttpConnection`

    - #### equals

          public boolean equals​(Object o)

      Overrides:
        `equals` in class `HttpConnection`

    - #### hashCode

          public int hashCode()

      Overrides:
        `hashCode` in class `HttpConnection`

    - #### getDelegate

          public HttpClientConnection getDelegate()

      Specified by:
        `getDelegate` in interface `HttpClient`
      Overrides:
        `getDelegate` in class `HttpConnection`

    - #### request

          public Future<HttpClientRequest> request()

      Create an HTTP request to send to the server with the default host and port of the client.
      Specified by:
        `request` in interface `HttpClient`
      Returns:
        a future notified when the request is ready to be sent

    - #### rxRequest

          public Single<HttpClientRequest> rxRequest()

      Create an HTTP request to send to the server with the default host and port of the client.
      Specified by:
        `rxRequest` in interface `HttpClient`
      Returns:
        a future notified when the request is ready to be sent

    - #### request

          public Future<HttpClientRequest> request​(RequestOptions options)

      Create an HTTP request to send to the server.
      Specified by:
        `request` in interface `HttpClient`
      Parameters:
        `options` - the request options
      Returns:
        a future notified when the request is ready to be sent

    - #### rxRequest

          public Single<HttpClientRequest> rxRequest​(RequestOptions options)

      Create an HTTP request to send to the server.
      Specified by:
        `rxRequest` in interface `HttpClient`
      Parameters:
        `options` - the request options
      Returns:
        a future notified when the request is ready to be sent

    - #### request

          public Future<HttpClientRequest> request​(HttpMethod method,
                                                   int port,
                                                   String host,
                                                   String requestURI)

      Create an HTTP request to send to the server at the `host` and `port`.
      Specified by:
        `request` in interface `HttpClient`
      Parameters:
        `method` - the HTTP method
        `port` - the port
        `host` - the host
        `requestURI` - the relative URI
      Returns:
        a future notified when the request is ready to be sent

    - #### rxRequest

          public Single<HttpClientRequest> rxRequest​(HttpMethod method,
                                                     int port,
                                                     String host,
                                                     String requestURI)

      Create an HTTP request to send to the server at the `host` and `port`.
      Specified by:
        `rxRequest` in interface `HttpClient`
      Parameters:
        `method` - the HTTP method
        `port` - the port
        `host` - the host
        `requestURI` - the relative URI
      Returns:
        a future notified when the request is ready to be sent

    - #### request

          public Future<HttpClientRequest> request​(HttpMethod method,
                                                   String host,
                                                   String requestURI)

      Create an HTTP request to send to the server at the `host` and default port.
      Specified by:
        `request` in interface `HttpClient`
      Parameters:
        `method` - the HTTP method
        `host` - the host
        `requestURI` - the relative URI
      Returns:
        a future notified when the request is ready to be sent

    - #### rxRequest

          public Single<HttpClientRequest> rxRequest​(HttpMethod method,
                                                     String host,
                                                     String requestURI)

      Create an HTTP request to send to the server at the `host` and default port.
      Specified by:
        `rxRequest` in interface `HttpClient`
      Parameters:
        `method` - the HTTP method
        `host` - the host
        `requestURI` - the relative URI
      Returns:
        a future notified when the request is ready to be sent

    - #### request

          public Future<HttpClientRequest> request​(HttpMethod method,
                                                   String requestURI)

      Create an HTTP request to send to the server at the default host and port.
      Specified by:
        `request` in interface `HttpClient`
      Parameters:
        `method` - the HTTP method
        `requestURI` - the relative URI
      Returns:
        a future notified when the request is ready to be sent

    - #### rxRequest

          public Single<HttpClientRequest> rxRequest​(HttpMethod method,
                                                     String requestURI)

      Create an HTTP request to send to the server at the default host and port.
      Specified by:
        `rxRequest` in interface `HttpClient`
      Parameters:
        `method` - the HTTP method
        `requestURI` - the relative URI
      Returns:
        a future notified when the request is ready to be sent

    - #### activeStreams

          public long activeStreams()

      Returns:
        the number of active request/response (streams)

    - #### maxActiveStreams

          public long maxActiveStreams()

      Returns:
        the max number of concurrent active streams this connection can handle

    - #### shutdown

          public Future<Void> shutdown()

      Description copied from class: `HttpConnection`
      Shutdown with a 30 seconds timeout (`shutdown(30, TimeUnit.SECONDS)`).
      Specified by:
        `shutdown` in interface `HttpClient`
      Overrides:
        `shutdown` in class `HttpConnection`
      Returns:
        a future completed when shutdown has completed

    - #### rxShutdown

          public Completable rxShutdown()

      Description copied from class: `HttpConnection`
      Shutdown with a 30 seconds timeout (`shutdown(30, TimeUnit.SECONDS)`).
      Specified by:
        `rxShutdown` in interface `HttpClient`
      Overrides:
        `rxShutdown` in class `HttpConnection`
      Returns:
        a future completed when shutdown has completed

    - #### shutdown

          public Future<Void> shutdown​(long timeout,
                                       TimeUnit unit)

      Description copied from class: `HttpConnection`
      Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight requests are processed, otherwise after a `timeout` the connection will be closed. Client connection are immediately removed from the pool.
      - HTTP/2 connections will send a go away frame immediately to signal the other side the connection will close.
      - HTTP/1.x connection will be closed.
      Specified by:
        `shutdown` in interface `HttpClient`
      Overrides:
        `shutdown` in class `HttpConnection`
      Parameters:
        `timeout` - the amount of time after which all resources are forcibly closed
        `unit` - the of the timeout
      Returns:
        a future completed when shutdown has completed

    - #### rxShutdown

          public Completable rxShutdown​(long timeout,
                                        TimeUnit unit)

      Description copied from class: `HttpConnection`
      Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight requests are processed, otherwise after a `timeout` the connection will be closed. Client connection are immediately removed from the pool.
      - HTTP/2 connections will send a go away frame immediately to signal the other side the connection will close.
      - HTTP/1.x connection will be closed.
      Specified by:
        `rxShutdown` in interface `HttpClient`
      Overrides:
        `rxShutdown` in class `HttpConnection`
      Parameters:
        `timeout` - the amount of time after which all resources are forcibly closed
        `unit` - the of the timeout
      Returns:
        a future completed when shutdown has completed

    - #### close

          public Future<Void> close()

      Description copied from class: `HttpConnection`
      Close immediately (`shutdown(0, TimeUnit.SECONDS`).
      Specified by:
        `close` in interface `HttpClient`
      Overrides:
        `close` in class `HttpConnection`
      Returns:
        a future notified when the client is closed

    - #### rxClose

          public Completable rxClose()

      Description copied from class: `HttpConnection`
      Close immediately (`shutdown(0, TimeUnit.SECONDS`).
      Specified by:
        `rxClose` in interface `HttpClient`
      Overrides:
        `rxClose` in class `HttpConnection`
      Returns:
        a future notified when the client is closed

    - #### newInstance

          public static HttpClientConnection newInstance​(HttpClientConnection arg)