This commit is contained in:
Redkale
2018-05-28 17:38:41 +08:00
parent 5c6f3c3712
commit 79de8dbbca

View File

@@ -60,7 +60,7 @@ public final class PrepareRunner implements Runnable {
new CompletionHandler<Integer, Void>() { new CompletionHandler<Integer, Void>() {
@Override @Override
public void completed(Integer count, Void attachment1) { public void completed(Integer count, Void attachment1) {
if (count < 1 && (!channel.isOpen() || buffer.remaining() == buffer.limit())) { if (count < 1) {
try { try {
response.request.offerReadBuffer(buffer); response.request.offerReadBuffer(buffer);
response.finish(true); response.finish(true);