Vert.x 4.5.13 · io.vertx.core.http.impl.HttpClientBase

Modifier and Type	Field and Description
protected final CloseFuture	closeFuture
private final Function<ContextInternal, ContextInternal>	contextProvider
private final boolean	keepAlive
protected final HttpClientMetrics<R, W, S, T>	metrics
protected final NetClientImpl	netClient
protected final HttpClientOptions	options
private final boolean	pipelining
private Predicate<SocketAddress>	proxyFilter
pack-priv final boolean	useH2UniformStreamByteDistributor
protected final VertxInternal	vertx
private final ConnectionManager<EndpointKey, HttpClientConnection>	webSocketCM

Modifier and Type

Field and Description

protected final CloseFuture

closeFuture

private final Function<ContextInternal, ContextInternal>

contextProvider

private final boolean

keepAlive

protected final HttpClientMetrics<R, W, S, T>

metrics

protected final NetClientImpl

netClient

protected final HttpClientOptions

options

private final boolean

pipelining

private Predicate<SocketAddress>

proxyFilter

pack-priv final boolean

useH2UniformStreamByteDistributor

protected final VertxInternal

vertx

private final ConnectionManager<EndpointKey, HttpClientConnection>

webSocketCM

Access	Constructor and Description
public	HttpClientBase(VertxInternal vertx, HttpClientOptions options, CloseFuture closeFuture)

Access

Constructor and Description

public

HttpClientBase(VertxInternal vertx, HttpClientOptions options, CloseFuture closeFuture)

Modifier and Type	Method and Description
public void	close(Promise<Void> the promise to signal when close has completed completion) Implements io.vertx.core.Closeable.close. Close this resource, the `completion` promise must be notified when the operation has completed.
public void	close(Handler<AsyncResult<Void>> handler)
public Future<Void>	close()
pack-priv Function<ContextInternal, ContextInternal>	contextProvider()
protected final String	getHost(RequestOptions request)
public Metrics	getMetrics() Implements io.vertx.core.spi.metrics.MetricsProvider.getMetrics. Returns the metrics implementation.
protected final int	getPort(RequestOptions request)
private ProxyOptions	getProxyOptions(ProxyOptions proxyOptions)
public boolean	isMetricsEnabled() Overrides default io.vertx.core.metrics.Measured.isMetricsEnabled. Whether the metrics are enabled for this measured object
pack-priv HttpClientMetrics<R, W, S, T>	metrics()
public NetClient	netClient()
public HttpClientOptions	options()
public HttpClientBase	proxyFilter(Predicate<SocketAddress> filter)
protected final ProxyOptions	resolveProxyOptions(ProxyOptions proxyOptions, SocketAddress addr)
public Future<Boolean>	updateSSLOptions(SSLOptions options, boolean force)
public VertxInternal	vertx()
public void	webSocket(WebSocketConnectOptions connectOptions, Handler<AsyncResult<WebSocket>> handler)
private void	webSocket(WebSocketConnectOptions connectOptions, PromiseInternal<WebSocket> promise)
public Future<WebSocket>	webSocket(int port, String host, String requestURI)
public Future<WebSocket>	webSocket(String host, String requestURI)
public Future<WebSocket>	webSocket(String requestURI)
public Future<WebSocket>	webSocket(WebSocketConnectOptions options)
public void	webSocket(int port, String host, String requestURI, Handler<AsyncResult<WebSocket>> handler)
public void	webSocket(String host, String requestURI, Handler<AsyncResult<WebSocket>> handler)
public void	webSocket(String requestURI, Handler<AsyncResult<WebSocket>> handler)
public Future<WebSocket>	webSocketAbs(String url, MultiMap headers, WebsocketVersion version, List<String> subProtocols)
public void	webSocketAbs(String url, MultiMap headers, WebsocketVersion version, List<String> subProtocols, Handler<AsyncResult<WebSocket>> handler)
private ConnectionManager<EndpointKey, HttpClientConnection>	webSocketConnectionManager()

Modifier and Type

Method and Description

public void

close(Promise<Void>

the promise to signal when close has completed

completion)

Implements io.vertx.core.Closeable.close.

Close this resource, the completion promise must be notified when the operation has completed.

public void

close(Handler<AsyncResult<Void>> handler)

public Future<Void>

close()

pack-priv Function<ContextInternal, ContextInternal>

contextProvider()

protected final String

getHost(RequestOptions request)

public Metrics

getMetrics()

Implements io.vertx.core.spi.metrics.MetricsProvider.getMetrics.

Returns the metrics implementation.

protected final int

getPort(RequestOptions request)

private ProxyOptions

getProxyOptions(ProxyOptions proxyOptions)

public boolean

isMetricsEnabled()

Overrides default io.vertx.core.metrics.Measured.isMetricsEnabled.

Whether the metrics are enabled for this measured object

pack-priv HttpClientMetrics<R, W, S, T>

metrics()

public NetClient

netClient()

public HttpClientOptions

options()

public HttpClientBase

proxyFilter(Predicate<SocketAddress> filter)

protected final ProxyOptions

resolveProxyOptions(ProxyOptions proxyOptions, SocketAddress addr)

public Future<Boolean>

updateSSLOptions(SSLOptions options, boolean force)

public VertxInternal

vertx()

public void

webSocket(WebSocketConnectOptions connectOptions, Handler<AsyncResult<WebSocket>> handler)

private void

webSocket(WebSocketConnectOptions connectOptions, PromiseInternal<WebSocket> promise)

public Future<WebSocket>

webSocket(int port, String host, String requestURI)

public Future<WebSocket>

webSocket(String host, String requestURI)

public Future<WebSocket>

webSocket(String requestURI)

public Future<WebSocket>

webSocket(WebSocketConnectOptions options)

public void

webSocket(int port, String host, String requestURI, Handler<AsyncResult<WebSocket>> handler)

public void

webSocket(String host, String requestURI, Handler<AsyncResult<WebSocket>> handler)

public void

webSocket(String requestURI, Handler<AsyncResult<WebSocket>> handler)

public Future<WebSocket>

webSocketAbs(String url, MultiMap headers, WebsocketVersion version, List<String> subProtocols)

public void

webSocketAbs(String url, MultiMap headers, WebsocketVersion version, List<String> subProtocols, Handler<AsyncResult<WebSocket>> handler)

private ConnectionManager<EndpointKey, HttpClientConnection>

webSocketConnectionManager()

Field Detail

closeFuture	back to summary
protected final CloseFuture closeFuture

contextProvider	back to summary
private final Function<ContextInternal, ContextInternal> contextProvider

keepAlive	back to summary
private final boolean keepAlive

metrics	back to summary
protected final HttpClientMetrics<R, W, S, T> metrics

netClient	back to summary
protected final NetClientImpl netClient

options	back to summary
protected final HttpClientOptions options

pipelining	back to summary
private final boolean pipelining

proxyFilter	back to summary
private Predicate<SocketAddress> proxyFilter

useH2UniformStreamByteDistributor	back to summary
pack-priv final boolean useH2UniformStreamByteDistributor

vertx	back to summary
protected final VertxInternal vertx

webSocketCM	back to summary
private final ConnectionManager<EndpointKey, HttpClientConnection> webSocketCM

HttpClientBase	back to summary
public HttpClientBase(VertxInternal vertx, HttpClientOptions options, CloseFuture closeFuture)

HttpClientBase

back to summary

public HttpClientBase(VertxInternal vertx, HttpClientOptions options, CloseFuture closeFuture)

Method Detail

close back to summary

close	back to summary
public void close(Promise<Void> completion) Implements io.vertx.core.Closeable.close. Doc from io.vertx.core.Closeable.close. Close this resource, the `completion` promise must be notified when the operation has completed. Parameters completion:Promise<Void> the promise to signal when close has completed Annotations @Override

public void close(Promise<Void> completion)

Implements io.vertx.core.Closeable.close.

Doc from io.vertx.core.Closeable.close.

Close this resource, the completion promise must be notified when the operation has completed.

Parameters

completion:Promise<Void>: the promise to signal when close has completed

Annotations

@Override

close	back to summary
public void close(Handler<AsyncResult<Void>> handler)

close	back to summary
public Future<Void> close()

contextProvider	back to summary
pack-priv Function<ContextInternal, ContextInternal> contextProvider()

getHost	back to summary
protected final String getHost(RequestOptions request)

getMetrics	back to summary
public Metrics getMetrics() Implements io.vertx.core.spi.metrics.MetricsProvider.getMetrics. Doc from io.vertx.core.spi.metrics.MetricsProvider.getMetrics. Returns the metrics implementation. Returns:Metrics the metrics Annotations @Override

getMetrics

back to summary

public Metrics getMetrics()

Implements io.vertx.core.spi.metrics.MetricsProvider.getMetrics.

Doc from io.vertx.core.spi.metrics.MetricsProvider.getMetrics.

Returns the metrics implementation.

Returns:Metrics

the metrics

Annotations

@Override

getPort	back to summary
protected final int getPort(RequestOptions request)

getProxyOptions	back to summary
private ProxyOptions getProxyOptions(ProxyOptions proxyOptions)

isMetricsEnabled back to summary

isMetricsEnabled	back to summary
public boolean isMetricsEnabled() Overrides default io.vertx.core.metrics.Measured.isMetricsEnabled. Doc from io.vertx.core.metrics.Measured.isMetricsEnabled. Whether the metrics are enabled for this measured object Returns:boolean `true` if metrics are enabled Annotations @Override

public boolean isMetricsEnabled()

Overrides default io.vertx.core.metrics.Measured.isMetricsEnabled.

Doc from io.vertx.core.metrics.Measured.isMetricsEnabled.

Whether the metrics are enabled for this measured object

Returns:boolean

true if metrics are enabled

Annotations

@Override

metrics	back to summary
pack-priv HttpClientMetrics<R, W, S, T> metrics()

netClient	back to summary
public NetClient netClient()

options	back to summary
public HttpClientOptions options()

proxyFilter	back to summary
public HttpClientBase proxyFilter(Predicate<SocketAddress> filter)

resolveProxyOptions	back to summary
protected final ProxyOptions resolveProxyOptions(ProxyOptions proxyOptions, SocketAddress addr)

updateSSLOptions	back to summary
public Future<Boolean> updateSSLOptions(SSLOptions options, boolean force)

vertx	back to summary
public VertxInternal vertx()

webSocket	back to summary
public void webSocket(WebSocketConnectOptions connectOptions, Handler<AsyncResult<WebSocket>> handler)

webSocket	back to summary
private void webSocket(WebSocketConnectOptions connectOptions, PromiseInternal<WebSocket> promise)

webSocket	back to summary
public Future<WebSocket> webSocket(int port, String host, String requestURI)

webSocket	back to summary
public Future<WebSocket> webSocket(String host, String requestURI)

webSocket	back to summary
public Future<WebSocket> webSocket(String requestURI)

webSocket	back to summary
public Future<WebSocket> webSocket(WebSocketConnectOptions options)

webSocket	back to summary
public void webSocket(int port, String host, String requestURI, Handler<AsyncResult<WebSocket>> handler)

webSocket	back to summary
public void webSocket(String host, String requestURI, Handler<AsyncResult<WebSocket>> handler)

webSocket	back to summary
public void webSocket(String requestURI, Handler<AsyncResult<WebSocket>> handler)

webSocketAbs	back to summary
public Future<WebSocket> webSocketAbs(String url, MultiMap headers, WebsocketVersion version, List<String> subProtocols)

webSocketAbs	back to summary
public void webSocketAbs(String url, MultiMap headers, WebsocketVersion version, List<String> subProtocols, Handler<AsyncResult<WebSocket>> handler)

webSocketConnectionManager	back to summary
private ConnectionManager<EndpointKey, HttpClientConnection> webSocketConnectionManager()

public Class HttpClientBase

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail