A test program to use the RX framework on the .net framework

test-rx.cs

using System;
using System.Collections.Generic;
using System.Linq;

// from http://themechanicalbride.blogspot.com/2009/07/introducing-rx-linq-to-events.html

class Program {

	static void Main ()
	{
		new NumbersObservable (new [] {2,3,4}).Subscribe (new DebugObserver ());
	}
}

internal class AnonymousDisposable : IDisposable
{
    internal Action Action {get; set;}

    void IDisposable.Dispose()
    {
        this.Action();
    }
}

class NumbersObservable : IObservable<int>
{
    public NumbersObservable(IEnumerable<int> numbers)
    {
        this._numbers = numbers;
    }

    private IEnumerable<int> _numbers;

    public IDisposable Subscribe(IObserver<int> observer)
    {
         foreach(int number in _numbers)
        {
             observer.OnNext(number);
        }
        observer.OnCompleted();

        return new AnonymousDisposable { Action = () => { ;  } }; 
    }
}

class DebugObserver : IObserver<int>
{
    public void OnNext(int value)
    {
        Console.WriteLine("{0}", value);
    }

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

    public void OnError(Exception ex)
    {
        Console.WriteLine("Whoops exception, I'd better throw.");
        throw ex;
    }
}