Listening to a single value from an Rx observable sequence

I have an observable sequence and I want to observe only a defined number of values, the number is immaterial, the important part is the fact I don't want to be notified of any further values.How can this can be achieved?The answer is easy, use the Rx extension method Take, it'll return the required number of values only. A simple example:.csharpcode, .csharpcode pre { font-size: small; color: black; font-family: Consolas, "Courier New",...

Read More

Applying LINQ principles to business logic

This was inspired by a conversation I was having with @leeoades & @hamishdotnet at work earlier this week, we were discussing the use of Yield keyword to short-cut method execution. Lee has a great post about sequences here. I wanted to get down how my thinking about the Yield keyword has now changed.Historically I've always thought about using the yield when I'm defining a custom enumerator method, something like GetFooEnumerator - typically...

Read More

How do I flatten an enumerable IObservable to IObservable?

The title of this post should be 'How do I flatten IObservable<IEnumerable<T>> to IObservable<T>?'But blogger says 'no'...This seems like a simple & legitimate Rx question and if you're one of the initiated it's very easy simple.It came up the other day because a back-end service we're talking to returned an array of stuff and we wanted to flatten it into a stream of single values we could observe.So what do I...

Read More

Does the Rx subscriber get disposed when OnCompleted is called?

We use an implementation of an observable command - ObservableCommand<T> in our view models not only to wire the actions of controls defined in the XAML but to allow the other interested parties to be notified when the command has executed.We were wondering what happens when the observable command is disposed, does the OnCompleted method for the subscribers get called and importantly are the subscribers disposed?Our observable command...

Read More

Using PostSharp for AOP with Reactive Extensions - update

After digging further into the use of AOP with Reactive Extensions my first post about can be improved by using the Do method instead of the Subscribe method on the IObservable<T> inside the AOP aspect OnExit method.Why?The previous implementation I gave would worked well for a hot observable, but for a cold observable this wouldn't apply as it would instantiate a new stream for each subscription setup in the aspect - Lee campbell...

Read More