From cf65c780c89c49ec4c2d28aac25736ebe9f907c5 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Fri, 16 Aug 2024 17:23:48 +0800
Subject: [PATCH] ClientFuture

---
 .../java/org/redkale/net/client/ClientConnection.java     | 4 ++--
 src/main/java/org/redkale/net/client/ClientFuture.java    | 8 ++++++++
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/redkale/net/client/ClientConnection.java b/src/main/java/org/redkale/net/client/ClientConnection.java
index a169b68ac..727bd7b6e 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
                 }
             };
 
-    protected final AtomicBoolean pauseWriting = new AtomicBoolean();
+    final AtomicBoolean pauseWriting = new AtomicBoolean();
 
     final ConcurrentLinkedQueue<ClientFuture> pauseRequests = new ConcurrentLinkedQueue<>();
 
     // pauseWriting=true，此字段才会有值; pauseWriting=false，此字段值为null
-    protected ClientFuture currHalfWriteFuture;
+    ClientFuture currHalfWriteFuture;
 
     @Nonnull
     private Client.AddressConnEntry connEntry;
diff --git a/src/main/java/org/redkale/net/client/ClientFuture.java b/src/main/java/org/redkale/net/client/ClientFuture.java
index daf12bedd..983d6fdd5 100644
--- a/src/main/java/org/redkale/net/client/ClientFuture.java
+++ b/src/main/java/org/redkale/net/client/ClientFuture.java
@@ -19,6 +19,8 @@ import org.redkale.util.Traces;
  */
 public class ClientFuture<R extends ClientRequest, T> extends CompletableFuture<T> implements Runnable {
 
+    public static final ClientFuture NIL = new ClientFuture() {};
+
     @Nonnull
     protected final R request;
 
@@ -27,6 +29,12 @@ public class ClientFuture<R extends ClientRequest, T> extends CompletableFuture<
 
     private ScheduledFuture timeout;
 
+    private ClientFuture() {
+        super();
+        this.conn = null;
+        this.request = null;
+    }
+
     ClientFuture(ClientConnection conn, R request) {
         super();
         Objects.requireNonNull(conn);