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 debugDatalastStreamId 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.