Default not specify timeout value

net-daemon · Aug 28, 2020 · 1d9a224 · 1d9a224
1 parent ac5d2fd
commit 1d9a224
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/src/App/NetDaemon.App/Common/Reactive/ObservableExtensionMethods.cs b/src/App/NetDaemon.App/Common/Reactive/ObservableExtensionMethods.cs
@@ -20,14 +20,23 @@ public static IObservable<(EntityState Old, EntityState New)> NDSameStateFor(thi
         }
 
         /// <summary>
-        ///     Is same for timespan time
+        ///     Wait for state the specified
         /// </summary>
         /// <param name="observable"></param>
         /// <param name="timeout">Timeout waiting for state</param>
-        /// <returns></returns>
-        public static IObservable<(EntityState Old, EntityState New)> NDFirstOrTimeout(this IObservable<(EntityState Old, EntityState New)> observable, TimeSpan timeout)
+        public static IObservable<(EntityState Old, EntityState New)> NDWaitForState(this IObservable<(EntityState Old, EntityState New)> observable, TimeSpan timeout)
         {
             return observable.Timeout(timeout, Observable.Return((new NetDaemon.Common.EntityState() { State = "TimeOut" }, new NetDaemon.Common.EntityState() { State = "TimeOut" }))).Take(1);
         }
+
+        /// <summary>
+        ///     Wait for state the default time
+        /// </summary>
+        /// <param name="observable"></param>
+        public static IObservable<(EntityState Old, EntityState New)> NDWaitForState(this IObservable<(EntityState Old, EntityState New)> observable)
+        {
+            return observable.Timeout(TimeSpan.FromSeconds(5), Observable.Return((new NetDaemon.Common.EntityState() { State = "TimeOut" }, new NetDaemon.Common.EntityState() { State = "TimeOut" }))).Take(1);
+        }
+
     }
 }