Remove invalid timeout path from AsyncWaitStrategy

disruptor-net · Jan 20, 2024 · 6bf90cf · 6bf90cf
1 parent dcc8602
commit 6bf90cf
Showing 1 changed file with 3 additions and 9 deletions.
diff --git a/src/Disruptor/AsyncWaitStrategy.cs b/src/Disruptor/AsyncWaitStrategy.cs
@@ -58,25 +58,21 @@ public async ValueTask<SequenceWaitResult> WaitForAsync(long sequence, Dependent
     {
         while (dependentSequences.CursorValue < sequence)
         {
-            var waitSucceeded = await WaitForAsyncImpl(sequence, dependentSequences, cancellationToken).ConfigureAwait(false);
-            if (!waitSucceeded)
-            {
-                return SequenceWaitResult.Timeout;
-            }
+            await WaitForAsyncImpl(sequence, dependentSequences, cancellationToken).ConfigureAwait(false);
         }
 
         return dependentSequences.AggressiveSpinWaitFor(sequence, cancellationToken);
     }
 
-    private async ValueTask<bool> WaitForAsyncImpl(long sequence, DependentSequenceGroup dependentSequences, CancellationToken cancellationToken)
+    private async ValueTask WaitForAsyncImpl(long sequence, DependentSequenceGroup dependentSequences, CancellationToken cancellationToken)
     {
         TaskCompletionSource<bool> tcs;
 
         lock (_gate)
         {
             if (dependentSequences.CursorValue >= sequence)
             {
-                return true;
+                return;
             }
 
             cancellationToken.ThrowIfCancellationRequested();
@@ -89,7 +85,5 @@ private async ValueTask<bool> WaitForAsyncImpl(long sequence, DependentSequenceG
         // the sequencer barrier after cancellation.
 
         await tcs.Task.ConfigureAwait(false);
-
-        return tcs.Task.IsCompleted;
     }
 }