From e1a88ef5d99d9dd65c7947c7f023407eea20ada3 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Fri, 16 Aug 2024 16:45:55 +0800
Subject: [PATCH] ClientConnection

---
 .../java/org/redkale/net/client/ClientConnection.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/org/redkale/net/client/ClientConnection.java b/src/main/java/org/redkale/net/client/ClientConnection.java
index 999bd6acf..a169b68ac 100644
--- a/src/main/java/org/redkale/net/client/ClientConnection.java
+++ b/src/main/java/org/redkale/net/client/ClientConnection.java
@@ -66,12 +66,12 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
                 }
             };
 
-    final AtomicBoolean pauseWriting = new AtomicBoolean();
+    protected final AtomicBoolean pauseWriting = new AtomicBoolean();
 
     final ConcurrentLinkedQueue<ClientFuture> pauseRequests = new ConcurrentLinkedQueue<>();
 
     // pauseWriting=true，此字段才会有值; pauseWriting=false，此字段值为null
-    ClientFuture currHalfWriteFuture;
+    protected ClientFuture currHalfWriteFuture;
 
     @Nonnull
     private Client.AddressConnEntry connEntry;
@@ -151,7 +151,7 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
         return respFuture;
     }
 
-    private void sendRequestInLocking(R request, ClientFuture respFuture) {
+    protected void sendRequestInLocking(R request, ClientFuture respFuture) {
         // 发送请求数据包
         writeArray.clear();
         request.writeTo(this, writeArray);
@@ -209,7 +209,7 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
         return Utility.allOfFutures(respFutures);
     }
 
-    private void sendRequestInLocking(ClientFuture[] respFutures) {
+    protected void sendRequestInLocking(ClientFuture[] respFutures) {
         // 发送请求数据包
         writeArray.clear();
         for (ClientFuture respFuture : respFutures) {