org.redkale.net

类 Response<C extends Context,R extends Request<C>>

java.lang.Object

org.redkale.net.Response<C,R>

类型参数:

C - Context的子类型

R - Request的子类型

直接已知子类:

HttpResponse, SncpResponse

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)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

context

protected final C extends Context context

bufferPool

protected final ObjectPool<java.nio.ByteBuffer> bufferPool

responsePool

protected final ObjectPool<Response> responsePool

request

protected final R extends Request<C> request

channel

protected AsyncConnection channel

writeHeadBuffer

protected java.nio.ByteBuffer writeHeadBuffer

writeBodyBuffer

protected java.nio.ByteBuffer writeBodyBuffer

output

protected java.lang.Object output

recycleListener

protected java.util.function.BiConsumer<R extends Request<C>,Response<C extends Context,R extends Request<C>>> recycleListener

filter

protected Filter<C extends Context,R extends Request<C>,? extends Response<C extends Context,R extends Request<C>>> filter

servlet

protected Servlet<C extends Context,R extends Request<C>,? extends Response<C extends Context,R extends Request<C>>> servlet

构造器详细资料

Response

protected Response(C context,
                   R request,
                   ObjectPool<Response> responsePool)

方法详细资料

pollWriteReadBuffer

protected java.nio.ByteBuffer pollWriteReadBuffer()

pollWriteBodyBuffer

protected java.nio.ByteBuffer pollWriteBodyBuffer()

getBodyBufferSupplier

protected java.util.function.Supplier<java.nio.ByteBuffer> getBodyBufferSupplier()

offerBuffer

protected void offerBuffer(java.nio.ByteBuffer... buffers)

removeChannel

protected AsyncConnection removeChannel()

prepare

protected void prepare()

recycle

protected boolean recycle()

refuseAlive

protected void refuseAlive()

init

protected void init(AsyncConnection channel)

setFilter

protected void setFilter(Filter<C,R,Response<C,R>> filter)

thenEvent

protected void thenEvent(Servlet servlet)

nextEvent

public void nextEvent()
               throws java.io.IOException

抛出:

java.io.IOException

recycleListener

public void recycleListener(java.util.function.BiConsumer<R,Response<C,R>> recycleListener)

getOutput

public java.lang.Object getOutput()

isClosed

public boolean isClosed()

是否已关闭

返回:

boolean

finish

public void finish()

finish

public void finish(boolean kill)

finish

public void finish(byte[] bs)

finish

public void finish(java.nio.ByteBuffer buffer)

finish

public void finish(boolean kill,
                   java.nio.ByteBuffer buffer)

finish

public void finish(java.nio.ByteBuffer... buffers)

finish

public void finish(boolean kill,
                   java.nio.ByteBuffer... buffers)

send

protected <A> void send(java.nio.ByteBuffer buffer,
                        A attachment,
                        java.nio.channels.CompletionHandler<java.lang.Integer,A> handler)

send

protected <A> void send(java.nio.ByteBuffer[] buffers,
                        A attachment,
                        java.nio.channels.CompletionHandler<java.lang.Integer,A> handler)

getContext

public C getContext()