public class PrepareRunner
extends java.lang.Object
implements java.lang.Runnable
详情见: https://redkale.org
构造器和说明 |
---|
PrepareRunner(Context context,
ObjectPool<Response> responsePool,
AsyncConnection channel,
java.nio.ByteBuffer data,
Response response) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
codec(java.nio.ByteBuffer buffer,
Response response) |
protected void |
initResponse(Response response,
AsyncConnection channel) |
protected void |
offerReadBuffer(Request request,
java.nio.ByteBuffer buffer) |
protected void |
offerReadBuffer(Response response,
java.nio.ByteBuffer buffer) |
protected java.nio.ByteBuffer |
pollReadBuffer(Request request) |
protected java.nio.ByteBuffer |
pollReadBuffer(Response response) |
protected Request |
pollRequest(Response response) |
protected Response |
pollResponse() |
protected AsyncConnection |
removeChannel(Response response) |
void |
run() |
public PrepareRunner(Context context, ObjectPool<Response> responsePool, AsyncConnection channel, java.nio.ByteBuffer data, Response response)
public void run()
run
在接口中 java.lang.Runnable
protected void codec(java.nio.ByteBuffer buffer, Response response) throws java.io.IOException
java.io.IOException
protected void initResponse(Response response, AsyncConnection channel)
protected Response pollResponse()
protected AsyncConnection removeChannel(Response response)
protected java.nio.ByteBuffer pollReadBuffer(Request request)
protected java.nio.ByteBuffer pollReadBuffer(Response response)
protected void offerReadBuffer(Request request, java.nio.ByteBuffer buffer)
protected void offerReadBuffer(Response response, java.nio.ByteBuffer buffer)