using System;

using System.Reactive.Linq;

using System.Threading;

​

public class Program

{

    public static void Main()

    {

        Observable

            .Timer(TimeSpan.FromMilliseconds(100))

            .Finally(() => throw new ApplicationException("Oops!"))

            .Subscribe(_ => { }, ex => Console.WriteLine(ex.Message),

                () => Console.WriteLine("Completed"));

​

        Thread.Sleep(1000);

    }

}

​