Further testing.

Dtronix · Aug 24, 2023 · c14096a · c14096a
1 parent 46897b1
commit c14096a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/NexNet.IntegrationTests/NexusServerTests_NexusDuplexPipe.cs b/src/NexNet.IntegrationTests/NexusServerTests_NexusDuplexPipe.cs
@@ -13,11 +13,11 @@ internal class NexusServerTests_NexusDuplexPipe : BasePipeTests
     [TestCase(Type.Quic)]
     public async Task PipeReaderReceivesDataMultipleTimes(Type type)
     {
-        var (_, sNexus, _, cNexus, tcs) = await Setup(type, true);
+        var (_, sNexus, _, cNexus, tcs) = await Setup(type);
         int count = 0;
 
         // Ensure that the ids will properly wrap around.
-        const int iterations = 1000;
+        const int iterations = 5000;
         sNexus.ServerTaskValueWithDuplexPipeEvent = async (nexus, pipe) =>
         {
             var result = await pipe.Input.ReadAsync();

diff --git a/src/NexNet/Internals/NexusSession.Sending.cs b/src/NexNet/Internals/NexusSession.Sending.cs
@@ -205,6 +205,8 @@ private async ValueTask SendHeaderCore(MessageType type, bool force, Cancellatio
         FlushResult result = default;
         try
         {
+            // If the cancellation token is canceled after the flush has completed, QUIC throws sometimes.
+            // https://github.com/dotnet/runtime/issues/82704
             result = await _pipeOutput.FlushAsync().ConfigureAwait(false);
         }
         catch (ObjectDisposedException)