gistfile1.cs

    public static class RandomStreamGenerator
    {
        private static Random _random = new Random();

        public static void GenerateIndefinitley<T>(Func<T> func, Action<T> onNext)
        {
            GenerateIndefinitley(func, 100, 1000, onNext);
        }

        public static void GenerateIndefinitley<T>(Func<T> func, int minMilliseconds, int maxMilliseconds, Action<T> onNext)
        {
            Observable.Defer(() =>
                             Observable.Return(func())
                                 .Delay(TimeSpan.FromMilliseconds(_random.Next(minMilliseconds, maxMilliseconds))))
                .Repeat().Subscribe(onNext);
        }

    }