From f34ec61458a18ee1a6b7a44a79f5886fbaccb9f1 Mon Sep 17 00:00:00 2001
From: Redkale <redkale@qq.com>
Date: Wed, 18 Jan 2023 11:22:09 +0800
Subject: [PATCH] =?UTF-8?q?ClientFuture=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/net/client/ClientCodec.java | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/main/java/org/redkale/net/client/ClientCodec.java b/src/main/java/org/redkale/net/client/ClientCodec.java
index 165deabd2..26b2f48db 100644
--- a/src/main/java/org/redkale/net/client/ClientCodec.java
+++ b/src/main/java/org/redkale/net/client/ClientCodec.java
@@ -27,7 +27,7 @@ import org.redkale.util.*;
  */
 public abstract class ClientCodec<R extends ClientRequest, P> implements CompletionHandler<Integer, ByteBuffer> {
 
-    protected final ClientConnection connection;
+    protected final ClientConnection<R, P> connection;
 
     private final List<ClientResponse<R, P>> respResults = new ArrayList<>();
 
@@ -35,7 +35,7 @@ public abstract class ClientCodec<R extends ClientRequest, P> implements Complet
 
     private final ObjectPool<ClientResponse<R, P>> respPool = ObjectPool.createUnsafePool(256, t -> new ClientResponse(), ClientResponse::prepare, ClientResponse::recycle);
 
-    public ClientCodec(ClientConnection connection) {
+    public ClientCodec(ClientConnection<R, P> connection) {
         Objects.requireNonNull(connection);
         this.connection = connection;
     }
@@ -153,8 +153,12 @@ public abstract class ClientCodec<R extends ClientRequest, P> implements Complet
         connection.dispose(t);
     }
 
+    protected R nextRequest() {
+        return connection.findRequest(null);
+    }
+
     protected R findRequest(Serializable requestid) {
-        return (R) connection.findRequest(requestid);
+        return connection.findRequest(requestid);
     }
 
     public void addMessage(R request, P result) {