Fixes throttling by passing through dueTime

dotnet · May 9, 2019 · eead46b · eead46b
1 parent 5906af9
commit eead46b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/Throttle.cs b/AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/Throttle.cs
@@ -134,7 +134,7 @@ public static (IAsyncObserver<TSource>, IAsyncDisposable) Throttle<TSource>(IAsy
                                         hasValue = false;
                                     }
                                 }
-                            }).ConfigureAwait(false);
+                            }, dueTime).ConfigureAwait(false);
                             await d.AssignAsync(t).ConfigureAwait(false);
                         },
                         async ex =>