This project is read-only.
SimpleRX is a reimplementation of many of the RX commands

Here is a simple example of the usage of the Concat operation:

IObservable<int> returnObject = Observable.Range(1, 4).Concat(Observable.Range(5, 5));
returnObject.Subscribe<int>(x =>
{
Debug.WriteLine(x);
},
ex => Console.WriteLine("OnError {0}", ex.Message),
() => Console.WriteLine("OnCompleted")
);

Output:
1
2
3
4
5
6
7
8
9

An description of the use of SimpleRX is shown at: http://netmatze.wordpress.com/2012/05/16/reimplementing-reactive-extensions-rx-part-2-observable-subjects-observableextensions-and-basesubject/
http://netmatze.wordpress.com/2012/05/16/reimplementing-reactive-extensions-rx-part-3-return-repeat-range-and-throw/
http://netmatze.wordpress.com/2012/05/18/reimplementing-reactive-extensions-rx-part-4-generate-and-generatewithtime/
http://netmatze.wordpress.com/2012/05/19/reimplementing-reactive-extensions-rx-part-5-contains-and-count/

Last edited Nov 7, 2012 at 10:37 AM by netmatze, version 17