Removed SuspendUntilFirstOrNone reactive operator

Author: stidsborg

Core/Cleipnir.ResilientFunctions.Tests/ReactiveTests/LeafOperatorsTests.cs

@@ -144,7 +144,7 @@ public async Task FirstOperatorWithSuspensionAndTimeoutEventReturnTimeoutOptionW
         var nextOrSuspend = await source
             .OfType<string>()
             .TakeUntilTimeout(timeoutEventId, expiresAt)
-            .SuspendUntilFirstOrNone();
+            .FirstOrNone(TimeSpan.Zero);
 
         nextOrSuspend.HasValue.ShouldBeFalse();
     }
@@ -163,7 +163,7 @@ public async Task FirstOperatorWithSuspensionAndTimeoutEventReturnsValueOnSignal
         var nextOrSuspend = await source
             .OfType<string>()
             .TakeUntilTimeout(timeoutEventId, expiresAt)
-            .SuspendUntilFirstOrNone();
+            .FirstOrNone(TimeSpan.Zero);
 
         nextOrSuspend.HasValue.ShouldBeTrue();
         nextOrSuspend.Value.ShouldBe("hallo");

Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/RFunctionTests/MessagingTests.cs

@@ -94,7 +94,7 @@ public async Task TimeoutEventCausesSuspendedFunctionToBeReInvoked(Task<IFunctio
                 var timeoutOption = await messages
                     .OfType<string>()
                     .TakeUntilTimeout("timeoutId1", expiresIn: TimeSpan.FromMilliseconds(250))
-                    .SuspendUntilFirstOrNone();
+                    .FirstOrNone(TimeSpan.Zero);
 
                 var timeoutEvent = messages
                     .OfType<TimeoutEvent>()

Core/Cleipnir.ResilientFunctions/Reactive/Extensions/LeafOperators.cs

@@ -84,12 +84,6 @@ internal static List<T> Existing<T>(this IReactiveChain<T> s, out bool streamCom
     }
 
     #region First
-    public static Task<Option<T>> SuspendUntilFirstOrNone<T>(this IReactiveChain<T> s, TimeSpan? maxWait = null)
-        => SuspendUntilFirsts(s, count: 1, maxWait)
-            .SelectAsync(emits => emits.Any()
-                ? new Option<T>(emits.Single())
-                : Option<T>.NoValue
-            );
     public static Task<List<T>> SuspendUntilFirsts<T>(this IReactiveChain<T> s, int count, TimeSpan? maxWait = null)
         => s.Take(count).ToList(maxWait: maxWait ?? TimeSpan.Zero);
 

Samples/Sample.ConsoleApp/SupportTicket/Saga.cs

@@ -27,7 +27,7 @@ await MessageBroker.Send(
                 .OfType<SupportTicketTaken>()
                 .Where(t => int.Parse(t.RequestId) == i)
                 .TakeUntilTimeout($"TimeoutId{i}", expiresIn: TimeSpan.FromMinutes(15))
-                .SuspendUntilFirstOrNone();
+                .FirstOrNone(TimeSpan.Zero);
 
             if (supportTicketTakenOption.HasValue)
                 return;