Fixed ODE caused by SetNoResult

sakno · sakno · commit c0230595a36a · 2025-08-19T20:46:15.000+03:00
diff --git a/src/cluster/DotNext.Net.Cluster/Net/Multiplexing/MultiplexedListener.Dispatcher.cs b/src/cluster/DotNext.Net.Cluster/Net/Multiplexing/MultiplexedListener.Dispatcher.cs
@@ -51,16 +51,15 @@ private async Task DispatchAsync(Socket socket)
         try
         {
             var receiveLoop = output.ProcessAsync(socket);
-            
             while (true)
             {
-                // rethrow exception from the receiving loop
-                if (receiveLoop.IsCompleted)
-                    await receiveLoop.ConfigureAwait(false);
-
                 try
                 {
-                    await input.ProcessAsync(receiveLoop.IsNotCompleted, socket).ConfigureAwait(false);
+                    // rethrow exception from the receiving loop
+                    await (receiveLoop.IsCompleted
+                            ? receiveLoop
+                            : input.ProcessAsync(receiveLoop.IsNotCompleted, socket))
+                        .ConfigureAwait(false);
                 }
                 catch (OperationCanceledException e) when (e.CancellationToken == lifetimeToken)
                 {

Original file line number	Diff line number	Diff line change
`@@ -51,16 +51,15 @@ private async Task DispatchAsync(Socket socket)`
`51`	`51`	`try`
`52`	`52`	`{`
`53`	`53`	`var receiveLoop = output.ProcessAsync(socket);`
`54`		`-`
`55`	`54`	`while (true)`
`56`	`55`	`{`
`57`		`- // rethrow exception from the receiving loop`
`58`		`- if (receiveLoop.IsCompleted)`
`59`		`- await receiveLoop.ConfigureAwait(false);`
`60`		`-`
`61`	`56`	`try`
`62`	`57`	`{`
`63`		`- await input.ProcessAsync(receiveLoop.IsNotCompleted, socket).ConfigureAwait(false);`
	`58`	`+ // rethrow exception from the receiving loop`
	`59`	`+ await (receiveLoop.IsCompleted`
	`60`	`+ ? receiveLoop`
	`61`	`+ : input.ProcessAsync(receiveLoop.IsNotCompleted, socket))`
	`62`	`+ .ConfigureAwait(false);`
`64`	`63`	`}`
`65`	`64`	`catch (OperationCanceledException e) when (e.CancellationToken == lifetimeToken)`
`66`	`65`	`{`