public class ServerInputBuffer extends InputBuffer
InputBuffer
.Constructor and Description |
---|
ServerInputBuffer() |
Modifier and Type | Method and Description |
---|---|
protected HttpContent |
blockingRead()
Read next chunk of data in this thread, block if needed.
|
protected Executor |
getThreadPool() |
void |
initialize(Request serverRequest,
FilterChainContext ctx) |
void |
initiateAsyncronousDataReceiving()
Initiates asynchronous data receiving.
|
void |
recycle()
Recycle this
InputBuffer for reuse. |
protected void |
updateInputContentBuffer(Buffer buffer) |
append, available, availableChar, close, fillFully, finished, getBuffer, getReadHandler, initialize, isAsyncEnabled, isClosed, isFinished, mark, markSupported, notifyAvailable, notifyAvailable, processingChars, read, read, read, readBuffer, readBuffer, readByte, readChar, ready, readyData, replayPayload, reset, setAsyncEnabled, setDefaultEncoding, skip, skip, terminate
public void initialize(Request serverRequest, FilterChainContext ctx)
public void initiateAsyncronousDataReceiving()
initiateAsyncronousDataReceiving
in class InputBuffer
protected HttpContent blockingRead() throws IOException
InputBuffer
blockingRead
in class InputBuffer
HttpContent
IOException
protected void updateInputContentBuffer(Buffer buffer)
updateInputContentBuffer
in class InputBuffer
public void recycle()
InputBuffer
Recycle this InputBuffer
for reuse.
recycle
in class InputBuffer
protected Executor getThreadPool()
getThreadPool
in class InputBuffer
Executor
, which will be used for notifying user
registered ReadHandler
.Copyright © 2015 Oracle Corporation. All rights reserved.