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 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 extends CompletableFuture implements Runnable { + public static final ClientFuture NIL = new ClientFuture() {}; + @Nonnull protected final R request; @@ -27,6 +29,12 @@ public class ClientFuture extends CompletableFuture< private ScheduledFuture timeout; + private ClientFuture() { + super(); + this.conn = null; + this.request = null; + } + ClientFuture(ClientConnection conn, R request) { super(); Objects.requireNonNull(conn);