diff --git a/src/main/java/org/redkale/net/AsyncConnection.java b/src/main/java/org/redkale/net/AsyncConnection.java index be7b625e3..381f6bd98 100644 --- a/src/main/java/org/redkale/net/AsyncConnection.java +++ b/src/main/java/org/redkale/net/AsyncConnection.java @@ -360,17 +360,6 @@ public abstract class AsyncConnection implements Channel, AutoCloseable { write(bytes, offset, length, (byte[]) null, 0, 0, handler); } - final void write(ByteTuple header, ByteTuple body, CompletionHandler handler) { - write( - header.content(), - header.offset(), - header.length(), - body == null ? null : body.content(), - body == null ? 0 : body.offset(), - body == null ? 0 : body.length(), - handler); - } - void write( byte[] headerContent, int headerOffset, @@ -488,14 +477,6 @@ public abstract class AsyncConnection implements Channel, AutoCloseable { } } - public final void writeInIOThread(ByteTuple header, ByteTuple body, CompletionHandler handler) { - if (inCurrWriteThread()) { - write(header, body, handler); - } else { - executeWrite(() -> write(header, body, handler)); - } - } - public final void writeInIOThread( byte[] headerContent, int headerOffset, diff --git a/src/main/java/org/redkale/net/Response.java b/src/main/java/org/redkale/net/Response.java index b6f0cb9d8..daafcbe18 100644 --- a/src/main/java/org/redkale/net/Response.java +++ b/src/main/java/org/redkale/net/Response.java @@ -345,10 +345,6 @@ public abstract class Response> { } } - protected void writeInIOThread(ByteBuffer buffer) { - this.channel.writeInIOThread(buffer, buffer, finishBufferIOThreadHandler); - } - public final void finish(final byte[] bs) { finish(false, bs, 0, bs.length); }