diff --git a/lib/src/main/java/com/blanke/xsocket/tcp/client/XTcpClient.java b/lib/src/main/java/com/blanke/xsocket/tcp/client/XTcpClient.java index e5f0506..b4cc74d 100644 --- a/lib/src/main/java/com/blanke/xsocket/tcp/client/XTcpClient.java +++ b/lib/src/main/java/com/blanke/xsocket/tcp/client/XTcpClient.java @@ -70,7 +70,7 @@ public static XTcpClient getTcpClient(Socket socket, TargetInfo targetInfo) { } public static XTcpClient getTcpClient(Socket socket, TargetInfo targetInfo, TcpConnConfig connConfig) { - if (!socket.isConnected()) { + if (!socket.isClosed()) { ExceptionUtils.throwException("socket is closeed"); } XTcpClient xTcpClient = new XTcpClient();