We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 49f6f28 commit 17bcbb0Copy full SHA for 17bcbb0
2 files changed
Core/Cleipnir.ResilientFunctions/Helpers/ForeverTask.cs
@@ -0,0 +1,8 @@
1
+using System.Threading.Tasks;
2
+
3
+namespace Cleipnir.ResilientFunctions.Helpers;
4
5
+public static class ForeverTask
6
+{
7
+ public static Task Instance { get; } = new TaskCompletionSource().Task;
8
+}
Core/Cleipnir.ResilientFunctions/Queuing/QueueManager.cs
@@ -153,7 +153,7 @@ internal void Interrupt()
153
finally
154
{
155
if (!_flowState.TryResumeSubflow())
156
- await new TaskCompletionSource<MessageData?>().Task;
+ await ForeverTask.Instance;
157
158
await delayCts.CancelAsync();
159
delayCts.Dispose();
0 commit comments