From 0895c825258ecfae61091b3c435e8d8c20c73c77 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Thu, 31 Oct 2024 08:47:56 +0800
Subject: [PATCH] AsyncConnection

---
 .../java/org/redkale/net/AsyncConnection.java | 36 -------------------
 1 file changed, 36 deletions(-)

diff --git a/src/main/java/org/redkale/net/AsyncConnection.java b/src/main/java/org/redkale/net/AsyncConnection.java
index 1c74a87f9..8806c0653 100644
--- a/src/main/java/org/redkale/net/AsyncConnection.java
+++ b/src/main/java/org/redkale/net/AsyncConnection.java
@@ -289,28 +289,6 @@ public abstract class AsyncConnection implements Channel, AutoCloseable {
         }
     }
 
-    public final void readRegisterInIOThread(CompletionHandler<Integer, ByteBuffer> handler) {
-        if (inCurrReadThread()) {
-            readRegister(handler);
-        } else {
-            executeRead(() -> readRegister(handler));
-        }
-    }
-
-    public final void readRegisterInIOThreadSafe(CompletionHandler<Integer, ByteBuffer> handler) {
-        if (inCurrReadThread()) {
-            if (!readPending) {
-                readRegister(handler);
-            }
-        } else {
-            executeRead(() -> {
-                if (!readPending) {
-                    readRegister(handler);
-                }
-            });
-        }
-    }
-
     public final void read(CompletionHandler<Integer, ByteBuffer> handler) {
         if (sslEngine == null) {
             readImpl(handler);
@@ -327,20 +305,6 @@ public abstract class AsyncConnection implements Channel, AutoCloseable {
         }
     }
 
-    public final void readInIOThreadSafe(CompletionHandler<Integer, ByteBuffer> handler) {
-        if (inCurrReadThread()) {
-            if (!readPending) {
-                read(handler);
-            }
-        } else {
-            executeRead(() -> {
-                if (!readPending) {
-                    read(handler);
-                }
-            });
-        }
-    }
-
     // src写完才会回调
     public final <A> void write(ByteBuffer src, A attachment, CompletionHandler<Integer, ? super A> handler) {
         if (sslEngine == null) {