using System;

using System.Reactive.Linq;

using System.Threading;

​

public class Program

{

    public static void Main()

    {

        Observable

            .Range(1,5) // simulates stream-reader

            .Finally(() => Console.WriteLine("Close streamreader"))

            .Do(i => {

                if (i == 5) {

                    throw new ApplicationException("Oops!"); // simulates IO-error

                }

                Console.WriteLine("Read " + i);

            })

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

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

​

        Thread.Sleep(1000);

    }

}

​