Quick.Protocol.Pipeline fit for net6.0.

Author: aaasoft

Quick.Protocol.Pipeline/QpPipelineClient.cs

@@ -22,11 +22,7 @@ public QpPipelineClient(QpPipelineClientOptions options) : base(options)
         protected override async Task<Stream> InnerConnectAsync()
         {
             pipeClientStream = new NamedPipeClientStream(options.ServerName, options.PipeName, PipeDirection.InOut, PipeOptions.Asynchronous);
-#if NETSTANDARD2_0
             await pipeClientStream.ConnectAsync(options.ConnectionTimeout);
-#else
-            await Task.Run(() => pipeClientStream.Connect(options.ConnectionTimeout));
-#endif
             pipeClientStream.ReadMode = PipeTransmissionMode.Byte;
             return pipeClientStream;
         }

Quick.Protocol.Pipeline/QpPipelineServer.cs

@@ -30,11 +30,7 @@ protected override Task InnerAcceptAsync(CancellationToken token)
         {
             var serverStream = new NamedPipeServerStream(options.PipeName, PipeDirection.InOut, NamedPipeServerStream.MaxAllowedServerInstances, PipeTransmissionMode.Byte, PipeOptions.Asynchronous);
             Task waitForConnectionTask = null;
-#if NETSTANDARD2_0
             waitForConnectionTask = serverStream.WaitForConnectionAsync(token);
-#else
-            waitForConnectionTask = Task.Run(() => serverStream.WaitForConnection());
-#endif
             return waitForConnectionTask.ContinueWith(task =>
             {
                 if (task.IsCanceled)

Quick.Protocol.Tcp/QpTcpClient.cs

@@ -42,9 +42,7 @@ public override void Disconnect()
             if (tcpClient != null)
             {
                 tcpClient.Close();
-#if NETSTANDARD2_0
                 tcpClient.Dispose();
-#endif
                 tcpClient = null;
             }
 

Test/ConsoleTest/Program.cs

@@ -16,7 +16,6 @@ static void Main(string[] args)
                 var psi = new ProcessStartInfo("dotnet");
                 psi.ArgumentList.Add($"{nameof(ConsoleTest)}.dll");
                 psi.ArgumentList.Add("client");
-                //psi.WorkingDirectory = typeof(Program);
                 psi.CreateNoWindow = true;
                 psi.UseShellExecute = false;
                 psi.RedirectStandardOutput = true;