class HttpFilter extends Filter<HttpRequest,HttpResponse,java.nio.ByteBuffer,java.nio.ByteBuffer>
Modifier and Type | Field and Description |
---|---|
private HttpParser |
httpParser |
downstreamFilter, upstreamFilter
Constructor and Description |
---|
HttpFilter(Filter<java.nio.ByteBuffer,java.nio.ByteBuffer,?,?> downstreamFilter,
int maxHeaderSize,
int maxBufferSize)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
private void |
addTransportHeaders(HttpRequest httpRequest) |
private void |
prepareForReply(HttpRequest httpRequest,
CompletionHandler<HttpRequest> completionHandler) |
(package private) boolean |
processRead(java.nio.ByteBuffer data)
Process
Filter.onRead(Object) . |
(package private) void |
write(HttpRequest httpRequest,
CompletionHandler<HttpRequest> completionHandler)
Perform write operation for this filter and invokes write method on the next filter in the filter chain.
|
private void |
writeBody(HttpRequest httpRequest,
CompletionHandler<HttpRequest> completionHandler) |
close, connect, handleConnect, onConnect, onConnectionClosed, onError, onRead, onSslHandshakeCompleted, processConnect, processConnectionClosed, processError, processSslHandshakeCompleted, startSsl
private final HttpParser httpParser
HttpFilter(Filter<java.nio.ByteBuffer,java.nio.ByteBuffer,?,?> downstreamFilter, int maxHeaderSize, int maxBufferSize)
downstreamFilter
- downstream filter. Accessible directly as Filter.downstreamFilter
protected field.void write(HttpRequest httpRequest, CompletionHandler<HttpRequest> completionHandler)
Filter
write
in class Filter<HttpRequest,HttpResponse,java.nio.ByteBuffer,java.nio.ByteBuffer>
httpRequest
- on which write operation is performed.completionHandler
- will be invoked when the write operation is completed or has failed.private void writeBody(HttpRequest httpRequest, CompletionHandler<HttpRequest> completionHandler)
private void prepareForReply(HttpRequest httpRequest, CompletionHandler<HttpRequest> completionHandler)
boolean processRead(java.nio.ByteBuffer data)
Filter
Filter.onRead(Object)
.processRead
in class Filter<HttpRequest,HttpResponse,java.nio.ByteBuffer,java.nio.ByteBuffer>
data
- read data.true
if the data should be sent to processing to upper filter in the chain, false
otherwise.Filter.onRead(Object).
private void addTransportHeaders(HttpRequest httpRequest)