private class HttpConnection.ConnectionFilter extends Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
downstreamFilter, upstreamFilter
Constructor and Description |
---|
ConnectionFilter(Filter<HttpRequest,HttpResponse,?,?> downstreamFilter) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
processConnect()
Process
Filter.onConnect() . |
(package private) void |
processConnectionClosed()
Process
Filter.onConnectionClosed() . |
(package private) void |
processError(java.lang.Throwable t)
Process
Filter.onError(Throwable) . |
(package private) boolean |
processRead(HttpResponse response)
Process
Filter.onRead(Object) . |
(package private) void |
processSslHandshakeCompleted()
Process
Filter.onSslHandshakeCompleted() . |
(package private) void |
write(HttpRequest data,
CompletionHandler<HttpRequest> completionHandler)
Perform write operation for this filter and invokes write method on the next filter in the filter chain.
|
close, connect, handleConnect, onConnect, onConnectionClosed, onError, onRead, onSslHandshakeCompleted, startSsl
ConnectionFilter(Filter<HttpRequest,HttpResponse,?,?> downstreamFilter)
boolean processRead(HttpResponse response)
Filter
Filter.onRead(Object)
.processRead
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
response
- read data.true
if the data should be sent to processing to upper filter in the chain, false
otherwise.Filter.onRead(Object).
void processConnect()
Filter
Filter.onConnect()
.processConnect
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
Filter.onConnect()
void processSslHandshakeCompleted()
Filter
Filter.onSslHandshakeCompleted()
.processSslHandshakeCompleted
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
Filter.onSslHandshakeCompleted()
void processConnectionClosed()
Filter
Filter.onConnectionClosed()
.processConnectionClosed
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
Filter.onConnectionClosed()
void processError(java.lang.Throwable t)
Filter
Filter.onError(Throwable)
.processError
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
t
- an error that has occurred.Filter.onError(Throwable)
void write(HttpRequest data, CompletionHandler<HttpRequest> completionHandler)
Filter
write
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
data
- on which write operation is performed.completionHandler
- will be invoked when the write operation is completed or has failed.