We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent af91ded commit c8e683dCopy full SHA for c8e683d
1 file changed
Core/Cleipnir.ResilientFunctions/Queuing/QueueManager.cs
@@ -251,7 +251,7 @@ public async Task AfterFlush()
251
if (_thrownException != null)
252
throw _thrownException;
253
254
- var (matched, positionToRemoveIndex, pulseTask) = TryTakeMessage(predicate);
+ var (matched, positionToRemoveIndex, interruptSignal) = TryTakeMessage(predicate);
255
if (matched != null)
256
{
257
var toRemoveId = new EffectId([-1, 0, positionToRemoveIndex]);
@@ -272,7 +272,7 @@ public async Task AfterFlush()
272
return matched.Envelope;
273
}
274
275
- await Task.WhenAny(pulseTask, timeoutTask, maxWaitTask);
+ await Task.WhenAny(interruptSignal, timeoutTask, maxWaitTask);
276
277
if (timeoutTask.IsCompleted)
278
return null;
0 commit comments