public class HttpConnection extends Object
close()
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.
|
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() |
static HttpConnection |
newInstance(HttpConnection arg) |
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() |
Http2Settings |
remoteSettings() |
HttpConnection |
remoteSettingsHandler(Handler<Http2Settings> handler)
Set an handler that is called when remote endpoint
Http2Settings are updated. |
Single<Buffer> |
rxPing(Buffer data)
Send a frame to the remote endpoint.
|
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.
|
HttpConnection |
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.
|
HttpConnection |
shutdown(long timeoutMs)
Like
shutdown() but with a configurable timeout value. |
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 the server 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 HttpConnection shutdown()
public HttpConnection shutdown(long timeoutMs)
shutdown()
but with a configurable timeout value.timeoutMs
- the timeout in millisecondspublic HttpConnection closeHandler(Handler<Void> handler)
handler
- the handler to be notifiedpublic void close()
public Http2Settings settings()
public HttpConnection updateSettings(Http2Settings settings)
settings
- the new settingspublic 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 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 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)public SocketAddress localAddress()
null
(e.g a server bound on a domain socket)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.