Top Description Inners Fields Constructors Methods
io.vertx.core.http.impl

pack-priv Class WebSocketEndpoint

extends ClientHttpEndpointBase<HttpClientConnection>
Class Inheritance
Imports
io.vertx.core.AsyncResult, .Future, .Handler, io.vertx.core.impl.ContextInternal, io.vertx.core.spi.metrics.ClientMetrics, java.util.ArrayDeque, .Deque
Set of connections (not pooled) to a host used for WebSocket.
Author
Julien Viet

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
WebSocketEndpoint.Waiter

Field Summary

Modifier and TypeField and Description
private final HttpChannelConnector
connector

private int
inflightConnections

private final int
maxPoolSize

private final Deque<WebSocketEndpoint.Waiter>
waiters

Constructor Summary

AccessConstructor and Description
pack-priv
WebSocketEndpoint(ClientMetrics<M, T, Req, Resp> metrics, int maxPoolSize, HttpChannelConnector connector, Runnable dispose)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
checkExpired()

Implements abstract io.vertx.core.http.impl.ClientHttpEndpointBase.checkExpired.

public void
close()

Overrides io.vertx.core.net.impl.pool.Endpoint.close.

Close the endpoint, this will close all connections, this method is called by the ConnectionManager when it is closed.

private void
connect(ContextInternal ctx, Handler<AsyncResult<HttpClientConnection>> handler)

private void
release()

public void
requestConnection2(ContextInternal ctx, long timeout, Handler<AsyncResult<HttpClientConnection>> handler)

Implements abstract io.vertx.core.http.impl.ClientHttpEndpointBase.requestConnection2.

private boolean
tryAcquire(ContextInternal ctx, Handler<AsyncResult<HttpClientConnection>> handler)

Inherited from io.vertx.core.http.impl.ClientHttpEndpointBase:
disposerequestConnection

Field Detail

connectorback to summary
private final HttpChannelConnector connector
inflightConnectionsback to summary
private int inflightConnections
maxPoolSizeback to summary
private final int maxPoolSize
waitersback to summary
private final Deque<WebSocketEndpoint.Waiter> waiters

Constructor Detail

WebSocketEndpointback to summary
pack-priv WebSocketEndpoint(ClientMetrics<M, T, Req, Resp> metrics, int maxPoolSize, HttpChannelConnector connector, Runnable dispose)

Method Detail

checkExpiredback to summary
pack-priv void checkExpired()

Implements abstract io.vertx.core.http.impl.ClientHttpEndpointBase.checkExpired.

Annotations
@Override
closeback to summary
public void close()

Overrides io.vertx.core.net.impl.pool.Endpoint.close.

Doc from io.vertx.core.net.impl.pool.Endpoint.close.

Close the endpoint, this will close all connections, this method is called by the ConnectionManager when it is closed.

Annotations
@Override
connectback to summary
private void connect(ContextInternal ctx, Handler<AsyncResult<HttpClientConnection>> handler)
releaseback to summary
private void release()
requestConnection2back to summary
public void requestConnection2(ContextInternal ctx, long timeout, Handler<AsyncResult<HttpClientConnection>> handler)

Implements abstract io.vertx.core.http.impl.ClientHttpEndpointBase.requestConnection2.

Annotations
@Override
tryAcquireback to summary
private boolean tryAcquire(ContextInternal ctx, Handler<AsyncResult<HttpClientConnection>> handler)
io.vertx.core.http.impl back to summary

private Class WebSocketEndpoint.Waiter

extends Object
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final ContextInternal
context

pack-priv final Handler<AsyncResult<HttpClientConnection>>
handler

Constructor Summary

AccessConstructor and Description
pack-priv
Waiter(Handler<AsyncResult<HttpClientConnection>> handler, ContextInternal context)

Method Summary

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

contextback to summary
pack-priv final ContextInternal context
handlerback to summary
pack-priv final Handler<AsyncResult<HttpClientConnection>> handler

Constructor Detail

Waiterback to summary
pack-priv Waiter(Handler<AsyncResult<HttpClientConnection>> handler, ContextInternal context)