[Rx][IO]File System notification throttling via Reactive Extensions

ReactiveFileWatcher.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Dynamic;
using System.Reflection;
using System.Reactive.Linq;
using Rxx;
using System.IO;

namespace ConsoleApplication17
{
    class Program
    {
        static void Main(string[] args)
        {
            FileSystemWatcher fsw = new FileSystemWatcher(@"c:\temp\watchme");

            //Watch extension method provided by Rxx library. Otherwise
            //we would call "FromEventPattern" 5 times.
            var notificationFireHose = fsw.Watch(WatcherChangeTypes.All);

            //Group each notification by their path and then throttle each
            //filepath for 200 ms.
            var filteredNotifications = notificationFireHose
                .GroupBy(n => n.FullPath)
                .Select(g => g.Throttle(TimeSpan.FromMilliseconds(200)))
                .Merge();

            filteredNotifications.Subscribe(f => Console.WriteLine("File done: " + f.FullPath));

            Console.Read();

        }


    }

}