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 Object

协议响应对象

详情见: https://redkale.org

作者:

zhangjx

字段概要

字段

限定符和类型	字段和说明
protected AsyncConnection	channel
protected C	context
protected Filter<C,R,? extends Response<C,R>>	filter
protected Object	output
protected BiConsumer<R,Response<C,R>>	recycleListener
protected R	request
protected Servlet<C,R,? extends Response<C,R>>	servlet
protected ByteBuffer	writeBodyBuffer
protected ByteBuffer	writeHeadBuffer

构造器概要

构造器

限定符	构造器和说明
protected	Response(C context, R request)

方法概要

限定符和类型	方法和说明
void	finish()
void	finish(boolean kill)
void	finish(boolean kill, ByteBuffer... buffers)
void	finish(boolean kill, ByteBuffer buffer)
void	finish(byte[] bs)
void	finish(ByteBuffer... buffers)
void	finish(ByteBuffer buffer)
protected Supplier<ByteBuffer>	getBodyBufferSupplier()
C	getContext()
Object	getOutput()
protected void	init(AsyncConnection channel)
boolean	isClosed() 是否已关闭
void	nextEvent()
protected void	offerBuffer(ByteBuffer... buffers)
protected ByteBuffer	pollWriteBodyBuffer()
protected ByteBuffer	pollWriteReadBuffer()
protected void	prepare()
protected boolean	recycle()
void	recycleListener(BiConsumer<R,Response<C,R>> recycleListener)
protected void	refuseAlive()
protected AsyncConnection	removeChannel()
protected <A> void	send(ByteBuffer[] buffers, A attachment, CompletionHandler<Integer,A> handler)
protected <A> void	send(ByteBuffer buffer, A attachment, CompletionHandler<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

request

protected final R extends Request<C> request

channel

protected AsyncConnection channel

writeHeadBuffer

protected ByteBuffer writeHeadBuffer

writeBodyBuffer

protected ByteBuffer writeBodyBuffer

output

protected Object output

recycleListener

protected 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)

方法详细资料

pollWriteReadBuffer

protected ByteBuffer pollWriteReadBuffer()

pollWriteBodyBuffer

protected ByteBuffer pollWriteBodyBuffer()

getBodyBufferSupplier

protected Supplier<ByteBuffer> getBodyBufferSupplier()

offerBuffer

protected void offerBuffer(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 IOException

抛出:

IOException

recycleListener

public void recycleListener(BiConsumer<R,Response<C,R>> recycleListener)

getOutput

public 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(ByteBuffer buffer)

finish

public void finish(boolean kill,
                   ByteBuffer buffer)

finish

public void finish(ByteBuffer... buffers)

finish

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

send

protected <A> void send(ByteBuffer buffer,
                        A attachment,
                        CompletionHandler<Integer,A> handler)

send

protected <A> void send(ByteBuffer[] buffers,
                        A attachment,
                        CompletionHandler<Integer,A> handler)

getContext

public C getContext()