Edmondo Pentangelo

I guess the implementation of the Observable.Subscribe method that is coming out of Observable.Return just calls OnNext.

So in fact by subscribing you're calling yourself back with the value 1. 

Observable.Return<T>(T value) = new IObservable { Subscribe(observer) = observer.OnNext(value) }

Is RxLinq part of the Microsoft Tesla long term initiative ?

Just for the fun of it,

I've added an F# implementation of SelectMany and Select for IObservable in F#.

http://reactivelinq.codeplex.com/

holoed

http://fsharpcode.blogspot.com/

Very beautiful and simple.

I was so impressed by the simplicity of it all that I tried to do a sample implementation in C#.
Did I get it right?

http://reactivelinq.codeplex.com