发布版本：2.6.5

aaasoft · aaasoft · commit c121a4ae152d · 2025-12-01T15:44:39.000+08:00
diff --git a/QpTestClient/QpTestClient.csproj b/QpTestClient/QpTestClient.csproj
@@ -8,7 +8,7 @@
 		<Product>[QuickProtocol]测试客户端</Product>
 		<AssemblyTitle>[QuickProtocol]测试客户端</AssemblyTitle>
 		<Authors>scbeta</Authors>
-		<Version>2.6.4</Version>
+		<Version>2.6.5</Version>
 		<IsPackable>false</IsPackable>
 		<ApplicationIcon>logo.ico</ApplicationIcon>
 		<EnableWindowsTargeting>true</EnableWindowsTargeting>
diff --git a/Quick.Protocol.AllClients/Quick.Protocol.AllClients.csproj b/Quick.Protocol.AllClients/Quick.Protocol.AllClients.csproj
@@ -6,7 +6,7 @@
 	  <RepositoryUrl>https://github.com/QuickProtocol/QuickProtocol_CSharp</RepositoryUrl>
 	  <Copyright />
 	  <Authors>scbeta</Authors>
-	  <Version>2.6.4</Version>
+	  <Version>2.6.5</Version>
 	  <Company />
 	  <Description>Incluse in common usage QpClient implements.
 Common use:
diff --git a/Quick.Protocol.Pipeline/Quick.Protocol.Pipeline.csproj b/Quick.Protocol.Pipeline/Quick.Protocol.Pipeline.csproj
@@ -4,7 +4,7 @@
 		<TargetFramework>net8.0</TargetFramework>
 		<PackageProjectUrl>https://github.com/QuickProtocol</PackageProjectUrl>
 		<RepositoryUrl>https://github.com/QuickProtocol/QuickProtocol_CSharp</RepositoryUrl>
-		<Version>2.6.4</Version>
+		<Version>2.6.5</Version>
 		<Authors>scbeta</Authors>
 		<Company />
 		<Product>Quick.Protocol</Product>
diff --git a/Quick.Protocol.SerialPort/Quick.Protocol.SerialPort.csproj b/Quick.Protocol.SerialPort/Quick.Protocol.SerialPort.csproj
@@ -4,7 +4,7 @@
 		<TargetFramework>net8.0</TargetFramework>
 		<PackageProjectUrl>https://github.com/QuickProtocol</PackageProjectUrl>
 		<RepositoryUrl>https://github.com/QuickProtocol/QuickProtocol_CSharp</RepositoryUrl>
-		<Version>2.6.4</Version>
+		<Version>2.6.5</Version>
 		<Authors>scbeta</Authors>
 		<Company />
 		<Product>Quick.Protocol</Product>
diff --git a/Quick.Protocol.Tcp/Quick.Protocol.Tcp.csproj b/Quick.Protocol.Tcp/Quick.Protocol.Tcp.csproj
@@ -4,7 +4,7 @@
 		<TargetFramework>net8.0</TargetFramework>
 		<PackageProjectUrl>https://github.com/QuickProtocol</PackageProjectUrl>
 		<RepositoryUrl>https://github.com/QuickProtocol/QuickProtocol_CSharp</RepositoryUrl>
-		<Version>2.6.4</Version>
+		<Version>2.6.5</Version>
 		<Authors>scbeta</Authors>
 		<Company />
 		<Product>Quick.Protocol</Product>
diff --git a/Quick.Protocol.WebSocket.Client/Quick.Protocol.WebSocket.Client.csproj b/Quick.Protocol.WebSocket.Client/Quick.Protocol.WebSocket.Client.csproj
@@ -4,7 +4,7 @@
 		<TargetFramework>net8.0</TargetFramework>
 		<PackageProjectUrl>https://github.com/QuickProtocol</PackageProjectUrl>
 		<RepositoryUrl>https://github.com/QuickProtocol/QuickProtocol_CSharp</RepositoryUrl>
-		<Version>2.6.4</Version>
+		<Version>2.6.5</Version>
 		<Authors>scbeta</Authors>
 		<Company />
 		<Product>Quick.Protocol</Product>
diff --git a/Quick.Protocol.WebSocket.Server.AspNetCore/Quick.Protocol.WebSocket.Server.AspNetCore.csproj b/Quick.Protocol.WebSocket.Server.AspNetCore/Quick.Protocol.WebSocket.Server.AspNetCore.csproj
@@ -4,7 +4,7 @@
 		<TargetFramework>net8.0</TargetFramework>
 		<PackageProjectUrl>https://github.com/QuickProtocol</PackageProjectUrl>
 		<RepositoryUrl>https://github.com/QuickProtocol/QuickProtocol_CSharp</RepositoryUrl>
-		<Version>2.6.4</Version>
+		<Version>2.6.5</Version>
 		<Authors>scbeta</Authors>
 		<Company />
 		<Product>Quick.Protocol</Product>
diff --git a/Quick.Protocol/QpChannel_Recv.cs b/Quick.Protocol/QpChannel_Recv.cs
@@ -412,22 +412,22 @@ protected void BeginReadPackage(CancellationToken token)
         {
             lastReadDataTime = DateTime.Now;
             var pipe = new Pipe();
-            FillRecvPipeAsync(QpPackageHandler_Stream, pipe.Writer, token).ContinueWith(task =>
+            CheckRecvTimeoutAsync(token).ContinueWith(task =>
             {
                 if (task.IsFaulted)
                     OnReadError(task.Exception);
-                pipe.Writer.CompleteAsync(task.Exception);
             });
-            ReadRecvPipeAsync(pipe.Reader, token).ContinueWith(task =>
+            FillRecvPipeAsync(QpPackageHandler_Stream, pipe.Writer, token).ContinueWith(task =>
             {
                 if (task.IsFaulted)
                     OnReadError(task.Exception);
-                pipe.Reader.CompleteAsync(task.Exception);
+                pipe.Writer.CompleteAsync(task.Exception);
             });
-            CheckRecvTimeoutAsync(token).ContinueWith(task =>
+            ReadRecvPipeAsync(pipe.Reader, token).ContinueWith(task =>
             {
                 if (task.IsFaulted)
                     OnReadError(task.Exception);
+                pipe.Reader.CompleteAsync(task.Exception);
             });
         }
 
diff --git a/Quick.Protocol/Quick.Protocol.csproj b/Quick.Protocol/Quick.Protocol.csproj
@@ -6,7 +6,7 @@
 		<RepositoryUrl>https://github.com/QuickProtocol/QuickProtocol_CSharp</RepositoryUrl>
 		<Copyright />
 		<Authors>scbeta</Authors>
-		<Version>2.6.4</Version>
+		<Version>2.6.5</Version>
 		<Company />
 		<Description>A simple protocol for TCP,Pipeline,SerialPort,WebSocket.</Description>
 		<PackageIcon>logo.png</PackageIcon>

Original file line number	Diff line number	Diff line change
`@@ -412,22 +412,22 @@ protected void BeginReadPackage(CancellationToken token)`
`412`	`412`	`{`
`413`	`413`	`lastReadDataTime = DateTime.Now;`
`414`	`414`	`var pipe = new Pipe();`
`415`		`- FillRecvPipeAsync(QpPackageHandler_Stream, pipe.Writer, token).ContinueWith(task =>`
	`415`	`+ CheckRecvTimeoutAsync(token).ContinueWith(task =>`
`416`	`416`	`{`
`417`	`417`	`if (task.IsFaulted)`
`418`	`418`	`OnReadError(task.Exception);`
`419`		`- pipe.Writer.CompleteAsync(task.Exception);`
`420`	`419`	`});`
`421`		`- ReadRecvPipeAsync(pipe.Reader, token).ContinueWith(task =>`
	`420`	`+ FillRecvPipeAsync(QpPackageHandler_Stream, pipe.Writer, token).ContinueWith(task =>`
`422`	`421`	`{`
`423`	`422`	`if (task.IsFaulted)`
`424`	`423`	`OnReadError(task.Exception);`
`425`		`- pipe.Reader.CompleteAsync(task.Exception);`
	`424`	`+ pipe.Writer.CompleteAsync(task.Exception);`
`426`	`425`	`});`
`427`		`- CheckRecvTimeoutAsync(token).ContinueWith(task =>`
	`426`	`+ ReadRecvPipeAsync(pipe.Reader, token).ContinueWith(task =>`
`428`	`427`	`{`
`429`	`428`	`if (task.IsFaulted)`
`430`	`429`	`OnReadError(task.Exception);`
	`430`	`+ pipe.Reader.CompleteAsync(task.Exception);`
`431`	`431`	`});`
`432`	`432`	`}`
`433`	`433`