use TcpClient to run PerfTest

test/SuperSocket.Tests/IHostConfigurator.cs

@@ -23,6 +23,8 @@ public interface IHostConfigurator
 
         Socket CreateClient();
 
+        ValueTask<Socket> CreateConnectedClientAsync();
+
         ValueTask<Stream> GetClientStream(Socket socket);
 
         TextReader GetStreamReader(Stream stream, Encoding encoding);

test/SuperSocket.Tests/PerfTest.cs

@@ -61,7 +61,7 @@ private async Task<int> RunConnectionAsync(IHostConfigurator hostConfigurator, C
         {
             var round = 0;
 
-            using (var socket = hostConfigurator.CreateClient())
+            using (var socket = await hostConfigurator.CreateConnectedClientAsync())
             using (var clientStream = await hostConfigurator.GetClientStream(socket))
             using (var streamReader = new StreamReader(clientStream, Utf8Encoding, true))
             using (var streamWriter = new StreamWriter(clientStream, Utf8Encoding, 1024 * 1024 * 4))

test/SuperSocket.Tests/ProxyProtocolHostConfigurator.cs

@@ -75,5 +75,10 @@ public ValueTask KeepSequence()
         {
             return _innerHostConfigurator.KeepSequence();
         }
+
+        public ValueTask<Socket> CreateConnectedClientAsync()
+        {
+            return _innerHostConfigurator.CreateConnectedClientAsync();
+        }
     }
 }

test/SuperSocket.Tests/TcpHostConfigurator.cs

@@ -44,6 +44,13 @@ public Socket CreateClient()
             return socket;
         }
 
+        public async ValueTask<Socket> CreateConnectedClientAsync()
+        {
+            var serverAddress = this.GetServerEndPoint();
+            var client = new TcpClient();
+            await client.ConnectAsync(serverAddress);
+            return client.Client;
+        }
 
         public TextReader GetStreamReader(Stream stream, Encoding encoding)
         {

test/SuperSocket.Tests/UdpHostConfigurator.cs

@@ -144,5 +144,9 @@ public async ValueTask KeepSequence()
             await Task.Delay(200);
         }
 
+        public ValueTask<Socket> CreateConnectedClientAsync()
+        {
+            throw new NotSupportedException();
+        }
     }
 }