Rx .NET samples

Subscribing.cs

static void Main()
{
    IObservable<int> observable = Enumerable.Range(0, 10).ToObservable();
    
    // Long version
    observable.Subscribe(new IntObserver());
    
    // Short version (lambda)
    observable.Subscribe(Console.WriteLine)
    
    // Short version (method)
    observable.Subscribe(OnNextInt);
}

static void OnNextInt(int value)
{
    Console.WriteLine(value)
}

class IntObserver : IObserver<int>
{
    public void OnNext(int value)
    {
        Console.WriteLine(value);
    }

    public void OnError(Exception error)
    {
        Console.WriteLine("OnError");
    }

    public void OnCompleted()
    {
        Console.WriteLine("OnCompleted");
    }
}