public class HttpConnection extends Object
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
closeHandler(io.vertx.core.Handler<java.lang.Void>)
exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>)
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<HttpConnection> |
__TYPE_ARG |
Constructor and Description |
---|
HttpConnection(HttpConnection delegate) |
HttpConnection(Object delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the connection and all the currently active streams.
|
void |
close(Handler<AsyncResult<Void>> handler)
Close the connection and all the currently active streams.
|
HttpConnection |
closeHandler(Handler<Void> handler)
Set a close handler.
|
boolean |
equals(Object o) |
HttpConnection |
exceptionHandler(Handler<Throwable> handler)
Set an handler called when a connection error happens
|
HttpConnection |
getDelegate() |
int |
getWindowSize() |
HttpConnection |
goAway(long errorCode)
Like
goAway(long) with a last stream id -1 which means to disallow any new stream creation. |
HttpConnection |
goAway(long errorCode,
int lastStreamId)
Like
goAway(long) with no buffer. |
HttpConnection |
goAway(long errorCode,
int lastStreamId,
Buffer debugData)
Send a go away frame to the remote endpoint of the connection.
|
HttpConnection |
goAwayHandler(Handler<GoAway> handler)
Set an handler called when a frame is received.
|
int |
hashCode() |
String |
indicatedServerName()
Returns the SNI server name presented during the SSL handshake by the client.
|
boolean |
isSsl() |
SocketAddress |
localAddress() |
SocketAddress |
localAddress(boolean real)
|
static HttpConnection |
newInstance(HttpConnection arg) |
HttpConnection |
ping(Buffer data)
Send a frame to the remote endpoint.
|
HttpConnection |
ping(Buffer data,
Handler<AsyncResult<Buffer>> pongHandler)
Send a frame to the remote endpoint.
|
HttpConnection |
pingHandler(Handler<Buffer> handler)
Set an handler notified when a frame is received from the remote endpoint.
|
SocketAddress |
remoteAddress() |
SocketAddress |
remoteAddress(boolean real)
|
Http2Settings |
remoteSettings() |
HttpConnection |
remoteSettingsHandler(Handler<Http2Settings> handler)
Set an handler that is called when remote endpoint
Http2Settings are updated. |
Completable |
rxClose()
Close the connection and all the currently active streams.
|
Single<Buffer> |
rxPing(Buffer data)
Send a frame to the remote endpoint.
|
Completable |
rxShutdown()
Initiate a graceful connection shutdown, the connection is taken out of service and closed when all current requests
are processed, otherwise after 30 seconds the connection will be closed.
|
Completable |
rxShutdown(long timeout)
Like
shutdown(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but with a specific timeout in milliseconds. |
Completable |
rxUpdateSettings(Http2Settings settings)
Send to the remote endpoint an update of this endpoint settings
The
completionHandler will be notified when the remote endpoint has acknowledged the settings. |
Http2Settings |
settings() |
HttpConnection |
setWindowSize(int windowSize)
Update the current connection wide window size to a new size.
|
void |
shutdown()
Initiate a graceful connection shutdown, the connection is taken out of service and closed when all current requests
are processed, otherwise after 30 seconds the connection will be closed.
|
void |
shutdown(Handler<AsyncResult<Void>> handler)
Initiate a graceful connection shutdown, the connection is taken out of service and closed when all current requests
are processed, otherwise after 30 seconds the connection will be closed.
|
void |
shutdown(long timeout)
Like
shutdown(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but with a specific timeout in milliseconds. |
void |
shutdown(long timeout,
Handler<AsyncResult<Void>> handler)
Like
shutdown(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but with a specific timeout in milliseconds. |
HttpConnection |
shutdownHandler(Handler<Void> handler)
Set an handler called when a frame has been sent or received and all connections are closed.
|
SSLSession |
sslSession() |
String |
toString() |
HttpConnection |
updateSettings(Http2Settings settings)
Send to the remote endpoint an update of this endpoint settings
The
completionHandler will be notified when the remote endpoint has acknowledged the settings. |
HttpConnection |
updateSettings(Http2Settings settings,
Handler<AsyncResult<Void>> completionHandler)
Send to the remote endpoint an update of this endpoint settings
The
completionHandler will be notified when the remote endpoint has acknowledged the settings. |
public static final io.vertx.lang.rx.TypeArg<HttpConnection> __TYPE_ARG
public HttpConnection(HttpConnection delegate)
public HttpConnection(Object delegate)
public HttpConnection getDelegate()
public int getWindowSize()
-1
for HTTP/1.xpublic HttpConnection setWindowSize(int windowSize)
windowSize
- the new window sizepublic HttpConnection goAway(long errorCode)
goAway(long)
with a last stream id -1
which means to disallow any new stream creation.errorCode
- public HttpConnection goAway(long errorCode, int lastStreamId)
goAway(long)
with no buffer.errorCode
- lastStreamId
- public HttpConnection goAway(long errorCode, int lastStreamId, Buffer debugData)
errorCode
and debugData
lastStreamId
will be closed0
when all the remaining streams are closed this connection will be closed automaticallyerrorCode
- the error codelastStreamId
- the last stream iddebugData
- additional debug data sent to the remote endpointpublic HttpConnection goAwayHandler(Handler<GoAway> handler)
handler
- the handlerpublic HttpConnection shutdownHandler(Handler<Void> handler)
handler
- the handlerpublic void shutdown(Handler<AsyncResult<Void>> handler)
handler
- the handler called when shutdown has completedpublic void shutdown()
public Completable rxShutdown()
public void shutdown(long timeout, Handler<AsyncResult<Void>> handler)
shutdown(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but with a specific timeout
in milliseconds.timeout
- handler
- public void shutdown(long timeout)
shutdown(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but with a specific timeout
in milliseconds.timeout
- public Completable rxShutdown(long timeout)
shutdown(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but with a specific timeout
in milliseconds.timeout
- public HttpConnection closeHandler(Handler<Void> handler)
handler
- the handler to be notifiedpublic void close(Handler<AsyncResult<Void>> handler)
handler
- the handler to be completed when the connection is closedpublic void close()
public Completable rxClose()
public Http2Settings settings()
public HttpConnection updateSettings(Http2Settings settings, Handler<AsyncResult<Void>> completionHandler)
completionHandler
will be notified when the remote endpoint has acknowledged the settings.
This is not implemented for HTTP/1.x.settings
- the new settingscompletionHandler
- the handler notified when the settings have been acknowledged by the remote endpointpublic HttpConnection updateSettings(Http2Settings settings)
completionHandler
will be notified when the remote endpoint has acknowledged the settings.
This is not implemented for HTTP/1.x.settings
- the new settingspublic Completable rxUpdateSettings(Http2Settings settings)
completionHandler
will be notified when the remote endpoint has acknowledged the settings.
This is not implemented for HTTP/1.x.settings
- the new settingspublic Http2Settings remoteSettings()
public HttpConnection remoteSettingsHandler(Handler<Http2Settings> handler)
Http2Settings
are updated.
This is not implemented for HTTP/1.x.handler
- the handler for remote endpoint settingspublic HttpConnection ping(Buffer data, Handler<AsyncResult<Buffer>> pongHandler)
data
- the 8 bytes data of the framepongHandler
- an async result handler notified with pong reply or the failurepublic HttpConnection ping(Buffer data)
data
- the 8 bytes data of the framepublic Single<Buffer> rxPing(Buffer data)
data
- the 8 bytes data of the framepublic HttpConnection pingHandler(Handler<Buffer> handler)
handler
- the handler to be called when a is receivedpublic HttpConnection exceptionHandler(Handler<Throwable> handler)
handler
- the handlerpublic SocketAddress remoteAddress()
null
(e.g a server bound on a domain socket). If useProxyProtocol
is set to true
, the address returned will be of the actual connecting client.public SocketAddress remoteAddress(boolean real)
real
- public SocketAddress localAddress()
null
(e.g a server bound on a domain socket) If useProxyProtocol
is set to true
, the address returned will be of the proxy.public SocketAddress localAddress(boolean real)
real
- public boolean isSsl()
HttpConnection
is encrypted via SSL/TLS.public String indicatedServerName()
public SSLSession sslSession()
public static HttpConnection newInstance(HttpConnection arg)
Copyright © 2023 Eclipse. All rights reserved.