reactive/Rx.NET/Samples/HOL/CS/Excercise2/Step04/Program.cs

using System;
using System.Linq;
using System.Reactive.Linq;

namespace Excercise2
{
    class Program
    {
        static void Main(string[] args)
        {
            IObservable<int> source = Observable.Throw<int>(new Exception("Oops"));

            IDisposable subscription = source.Subscribe(
                x  => Console.WriteLine("OnNext:  {0}", x),
                ex => Console.WriteLine("OnError: {0}", ex.Message),
                () => Console.WriteLine("OnCompleted")
            );

            Console.WriteLine("Press ENTER to unsubscribe...");
            Console.ReadLine();
            
            subscription.Dispose();
        }
    }
}