Merge pull request #1767 from PathogenDavid/issue-1628

Fix GateInterval not working after the first tick
bonsai-rx · Apr 30, 2024 · eb3ef6f · eb3ef6f
2 parents d3317bb + 54b958a
commit eb3ef6f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Bonsai.Core/ObservableCombinators.cs b/Bonsai.Core/ObservableCombinators.cs
@@ -90,7 +90,7 @@ public static IObservable<TSource> Gate<TSource>(this IObservable<TSource> sourc
         /// </returns>
         public static IObservable<TSource> Gate<TSource>(this IObservable<TSource> source, TimeSpan interval, IScheduler scheduler)
         {
-            return Gate(source, Observable.Timer(interval, scheduler));
+            return Gate(source, Observable.Interval(interval, scheduler));
         }
 
         /// <summary>

diff --git a/Bonsai.Core/Reactive/GateInterval.cs b/Bonsai.Core/Reactive/GateInterval.cs
@@ -86,7 +86,7 @@ public override IObservable<TSource> Process<TSource>(IObservable<TSource> sourc
         {
             var dueTime = DueTime;
             var scheduler = HighResolutionScheduler.Default;
-            var interval = Observable.Timer(Interval, scheduler);
+            var interval = Observable.Interval(Interval, scheduler);
             return dueTime.HasValue
                 ? source.Gate(interval, dueTime.Value, scheduler)
                 : source.Gate(interval);