From e9d25a67f838bb449567fdf1f75ecb18522901ad Mon Sep 17 00:00:00 2001 From: redkale Date: Sat, 4 Feb 2023 20:21:41 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96client?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/org/redkale/net/client/ClientWriteIOThread.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/redkale/net/client/ClientWriteIOThread.java b/src/main/java/org/redkale/net/client/ClientWriteIOThread.java index 78d2bb7a7..2db79ab9d 100644 --- a/src/main/java/org/redkale/net/client/ClientWriteIOThread.java +++ b/src/main/java/org/redkale/net/client/ClientWriteIOThread.java @@ -60,7 +60,7 @@ public class ClientWriteIOThread extends AsyncIOThread { map.clear(); if (entry.resumeHalfRequestFlag != null) { //将暂停的pauseRequests写入list List cl = map.computeIfAbsent(entry.conn, c -> listPool.get()); - for (ClientFuture f : (List) entry.conn.pauseRequests) { + for (ClientFuture f : (Collection) entry.conn.pauseRequests) { if (!f.isDone()) { entry.conn.offerRespFuture(f); cl.add(f); @@ -79,7 +79,7 @@ public class ClientWriteIOThread extends AsyncIOThread { while ((entry = requestQueue.poll()) != null) { if (entry.resumeHalfRequestFlag != null) { //将暂停的pauseRequests写入list List cl = map.computeIfAbsent(entry.conn, c -> listPool.get()); - for (ClientFuture f : (List) entry.conn.pauseRequests) { + for (ClientFuture f : (Collection) entry.conn.pauseRequests) { if (!f.isDone()) { entry.conn.offerRespFuture(f); cl.add(f);