Merge pull request #386 from rabbitmq/rabbitmq-stream-dotnet-client-3…

…85-followup Follow-up to #385
rabbitmq · Jun 10, 2024 · 298d510 · 298d510
2 parents 14b6e2d + c006ff4
commit 298d510
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/RabbitMQ.Stream.Client/Client.cs b/RabbitMQ.Stream.Client/Client.cs
@@ -976,11 +976,13 @@ public bool RunContinuationsAsynchronously
         public void SetException(Exception error)
         {
             // https://github.com/rabbitmq/rabbitmq-stream-dotnet-client/issues/384
-            // we need to check if the task is pending before setting the exception
-            if (_logic.GetStatus(_logic.Version) == ValueTaskSourceStatus.Pending)
+            try
             {
                 _logic.SetException(error);
             }
+            catch (InvalidOperationException)
+            {
+            }
         }
 
         void IValueTaskSource.GetResult(short token) => _logic.GetResult(token);