using System;

using System.Reactive.Linq;

using System.Threading.Tasks;

​

public class Program

{

    public static async Task Main()

    {

        try

        {

            await Observable

                .Interval(TimeSpan.FromMilliseconds(100))

                .Select(x => (int)x + 1)

                .Take(5)

                .SelectMany(x => Observable.FromAsync(async ct =>

                {

                    await Task.Delay(500); // Simulate an I/O operation

                    if (x == 3) throw new ApplicationException("Oops!");

                    Console.WriteLine($"Operation #{x} completed");

                    return x;

                }))

                .Do(x => Console.WriteLine($"Result: {x}"));

        }

        catch (Exception ex)

        {

            Console.WriteLine($"Failed, {ex.GetType().Name}: {ex.Message}");

        }

        await Task.Delay(1000);

    }

}

​