C
- Context的子类型R
- Request的子类型public abstract class Response<C extends Context,R extends Request<C>>
extends java.lang.Object
详情见: https://redkale.org
限定符和类型 | 字段和说明 |
---|---|
protected ObjectPool<java.nio.ByteBuffer> |
bufferPool |
protected AsyncConnection |
channel |
protected C |
context |
protected Filter<C,R,? extends Response<C,R>> |
filter |
protected java.lang.Object |
output |
protected java.util.function.BiConsumer<R,Response<C,R>> |
recycleListener |
protected R |
request |
protected ObjectPool<Response> |
responsePool |
protected Servlet<C,R,? extends Response<C,R>> |
servlet |
protected java.nio.ByteBuffer |
writeBodyBuffer |
protected java.nio.ByteBuffer |
writeHeadBuffer |
限定符 | 构造器和说明 |
---|---|
protected |
Response(C context,
R request,
ObjectPool<Response> responsePool) |
限定符和类型 | 方法和说明 |
---|---|
void |
finish() |
void |
finish(boolean kill) |
void |
finish(boolean kill,
java.nio.ByteBuffer... buffers) |
void |
finish(boolean kill,
java.nio.ByteBuffer buffer) |
void |
finish(byte[] bs) |
void |
finish(java.nio.ByteBuffer... buffers) |
void |
finish(java.nio.ByteBuffer buffer) |
protected java.util.function.Supplier<java.nio.ByteBuffer> |
getBodyBufferSupplier() |
C |
getContext() |
java.lang.Object |
getOutput() |
protected void |
init(AsyncConnection channel) |
boolean |
isClosed()
是否已关闭
|
void |
nextEvent() |
protected void |
offerBuffer(java.nio.ByteBuffer... buffers) |
protected java.nio.ByteBuffer |
pollWriteBodyBuffer() |
protected java.nio.ByteBuffer |
pollWriteReadBuffer() |
protected void |
prepare() |
protected boolean |
recycle() |
void |
recycleListener(java.util.function.BiConsumer<R,Response<C,R>> recycleListener) |
protected void |
refuseAlive() |
protected AsyncConnection |
removeChannel() |
protected <A> void |
send(java.nio.ByteBuffer[] buffers,
A attachment,
java.nio.channels.CompletionHandler<java.lang.Integer,A> handler) |
protected <A> void |
send(java.nio.ByteBuffer buffer,
A attachment,
java.nio.channels.CompletionHandler<java.lang.Integer,A> handler) |
protected void |
setFilter(Filter<C,R,Response<C,R>> filter) |
protected void |
thenEvent(Servlet servlet) |
protected final ObjectPool<java.nio.ByteBuffer> bufferPool
protected final ObjectPool<Response> responsePool
protected AsyncConnection channel
protected java.nio.ByteBuffer writeHeadBuffer
protected java.nio.ByteBuffer writeBodyBuffer
protected java.lang.Object output
protected java.util.function.BiConsumer<R extends Request<C>,Response<C extends Context,R extends Request<C>>> recycleListener
protected Filter<C extends Context,R extends Request<C>,? extends Response<C extends Context,R extends Request<C>>> filter
protected Response(C context, R request, ObjectPool<Response> responsePool)
protected java.nio.ByteBuffer pollWriteReadBuffer()
protected java.nio.ByteBuffer pollWriteBodyBuffer()
protected java.util.function.Supplier<java.nio.ByteBuffer> getBodyBufferSupplier()
protected void offerBuffer(java.nio.ByteBuffer... buffers)
protected AsyncConnection removeChannel()
protected void prepare()
protected boolean recycle()
protected void refuseAlive()
protected void init(AsyncConnection channel)
protected void thenEvent(Servlet servlet)
public void nextEvent() throws java.io.IOException
java.io.IOException
public void recycleListener(java.util.function.BiConsumer<R,Response<C,R>> recycleListener)
public java.lang.Object getOutput()
public boolean isClosed()
public void finish()
public void finish(boolean kill)
public void finish(byte[] bs)
public void finish(java.nio.ByteBuffer buffer)
public void finish(boolean kill, java.nio.ByteBuffer buffer)
public void finish(java.nio.ByteBuffer... buffers)
public void finish(boolean kill, java.nio.ByteBuffer... buffers)
protected <A> void send(java.nio.ByteBuffer buffer, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,A> handler)
protected <A> void send(java.nio.ByteBuffer[] buffers, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,A> handler)
public C getContext()