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.Constructor and Description |
---|
HttpConnection(HttpConnection 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.
|
HttpConnection |
exceptionHandler(Handler<Throwable> handler)
Set an handler called when a connection error happens
|
Object |
getDelegate() |
int |
getWindowSize() |
HttpConnection |
goAway(long errorCode)
Like
goAway(long) with a last stream id 2^31-1 . |
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.
|
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.
|
Observable<Buffer> |
pingObservable(Buffer data)
Send a frame to the remote endpoint.
|
Http2Settings |
remoteSettings() |
HttpConnection |
remoteSettingsHandler(Handler<Http2Settings> handler)
Set an handler that is called when remote endpoint
Http2Settings are updated. |
Http2Settings |
settings() |
HttpConnection |
setWindowSize(int windowSize)
Update the current connection wide window size to a new size.
|
HttpConnection |
shutdown()
Initiate a connection shutdown, a go away frame is sent and the connection is closed when all current active streams
are closed or after a time out of 30 seconds.
|
HttpConnection |
shutdown(long timeoutMs)
Initiate a connection shutdown, a go away frame is sent and the connection is closed when all current streams
will be closed or the
timeout is fired. |
HttpConnection |
shutdownHandler(Handler<Void> handler)
Set an handler called when a frame has been sent or received and all connections are closed.
|
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. |
Observable<Void> |
updateSettingsObservable(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. |
public HttpConnection(HttpConnection delegate)
public Object 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 2^31-1
.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)
timeout
is fired.
This is not implemented for HTTP/1.x.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 Observable<Void> updateSettingsObservable(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 Observable<Buffer> pingObservable(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 static HttpConnection newInstance(HttpConnection arg)
Copyright © 2016. All rights reserved.