fizzbuzz.cs

            var fb = Observable.Range(1, 100).Publish();
            fb.Where(c1 => c1 % 3 == 0).Subscribe(c1 => Console.WriteLine("Fizz"));
            fb.Where(c2 => c2 % 5 == 0).Subscribe(c2 => Console.WriteLine("Buzz"));
            fb.Where(c3 => c3 % 3 != 0 && c3 % 5 != 0).Subscribe(c3 => Console.WriteLine(c3.ToString()));
            fb.Connect();

            var fb2 = new Subject<int>();
            fb2.Where(c1 => c1 % 3 == 0).Subscribe(c1 => Console.WriteLine("Fizz"));
            fb2.Where(c2 => c2 % 5 == 0).Subscribe(c2 => Console.WriteLine("Buzz"));
            fb2.Where(c3 => c3 % 3 != 0 && c3 % 5 != 0).Subscribe(c3 => Console.WriteLine(c3.ToString()));
            Observable.
                Range(1, 100).
                Do(xx => fb2.OnNext(xx)).
                Publish().
                Connect();