This commit is contained in:
@@ -158,6 +158,10 @@ public abstract class Response<C extends Context, R extends Request<C>> {
|
|||||||
this.context.responsePool.offer(this);
|
this.context.responsePool.offer(this);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void finish(final byte[] bs) {
|
||||||
|
finish(ByteBuffer.wrap(bs));
|
||||||
|
}
|
||||||
|
|
||||||
public void finish(ByteBuffer buffer) {
|
public void finish(ByteBuffer buffer) {
|
||||||
this.channel.write(buffer, buffer, finishHandler);
|
this.channel.write(buffer, buffer, finishHandler);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -356,6 +356,16 @@ public class HttpResponse extends Response<HttpContext, HttpRequest> {
|
|||||||
super.finish(buffer404.duplicate());
|
super.finish(buffer404.duplicate());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 将指定byte[]按响应结果输出
|
||||||
|
*
|
||||||
|
* @param bs 输出内容
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public void finish(final byte[] bs) {
|
||||||
|
finish(false, ByteBuffer.wrap(bs));
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 将指定ByteBuffer按响应结果输出
|
* 将指定ByteBuffer按响应结果输出
|
||||||
*
|
*
|
||||||
|
|||||||
Reference in New Issue
Block a user