anaisbetts

// Only let input Observable fire every 'n' seconds at most
// but unlike Throttle, items fire immediately when they aren't
// rate-limited.
public IObservable<T> RateLimit<T>(this IObservable<T> This, TimeSpan interval, IScheduler scheduler)
{
    var slot = default(IObservable<Unit>);
    var input = This.Publish().RefCount();

    return input.Window(input, _ => {
            if (slot != null) return slot;