完善管道处理逻辑。

Author: aaasoft

Quick.Protocol.Pipeline/QpPipelineClient.cs

@@ -21,14 +21,16 @@ public QpPipelineClient(QpPipelineClientOptions options) : base(options)
 
         protected override async Task<Stream> InnerConnectAsync()
         {
-            pipeClientStream = new NamedPipeClientStream(options.ServerName, options.PipeName, PipeDirection.InOut, PipeOptions.Asynchronous);
             try
             {
+                pipeClientStream = new NamedPipeClientStream(options.ServerName, options.PipeName, PipeDirection.InOut, PipeOptions.Asynchronous);
                 await pipeClientStream.ConnectAsync(options.ConnectionTimeout).ConfigureAwait(false);
             }
             catch
             {
-                pipeClientStream.Dispose();
+                try { pipeClientStream?.Dispose(); }
+                catch { }
+                pipeClientStream = null;
                 throw;
             }
             pipeClientStream.ReadMode = PipeTransmissionMode.Byte;