New Rxx Release (It’s a big one!)

We couldn’t let Rx go live without an Rxx refresh and boy is it a big one! Dave Sexton & I are proud to announce Rxx 1.1. Firstly let me congratulate Dave. This is a major milestone for us and he has put in a huge effort, much of which has been enhancing our build process. Rxx is now available in the following configurations!

Build Configurations

  • .NET Stable
  • .NET Experimental
  • Silverlight Stable
  • Silverlight Experimental
  • Windows Phone 7 Stable
  • Windows Phone 7 Experimental

Dave has spent the last month mirroring the Rx team’s build process, including documentation & labs, ported to their respective platforms. I guess we’re going to have to support XNA next! Of course there would be no point in doing all this if we didn’t have some useful features. Don’t worry there are plenty of new ones.

Major New Features

  • Rx Parsers
  • Rx Dns
  • Rx Smtp Clients
  • Rx Sockets
  • Rx Web Requests
  • Rx Network Changes
  • Rx Ping
  • A new type of Multicasting that allows state to be cleared when the observable goes “cold”.


Along with out new build process, we’ve incorporated a range of technologies to ensure that Rxx remains a high quality project;

  • Code Contracts
  • StyleCop Analysis
  • FxCop Analysis
  • Sandcastle Documentation
  • MS Test

Additionally Dave Sexton’s Labs abstraction means that our interactive labs run on each platform.

What’s next?

I’m really proud to be part of a project that is shaping up to be one of the most professional looking open source projects I’ve seen. The work that’s gone into our project in this release gives us a great platform to build on going forward. Head over to the project page & as always, we are eagerly awaiting any feedback or ideas you might have.


Rx Performance Improvements

I think being a technology that enables us to easily write multithreaded, concurrent applications, a question often asked is;

“how fast is this stuff?”

As Rx completes its metamorphosis from “labs project” to “official product”, it seems the team has started focusing on performance. This is probably quite normal as the project shifts from designing the perfect API to supporting a stable product.

I thought I’d share some benchmarks on where some of these improvements have been made.



Subjects are used everywhere in Rx, so its a good candidate for optimisation, giving us across the board performance gains. I’m testing the throughput by publishing 1 million notifications.

// Subject thoughput performance test
var subject = new Subject<int>();
subject.Subscribe(_ => { });
var sw = Stopwatch.StartNew();
for (int i = 0; i < 1000000; i++)


1.0.2698.104 – 2.38 seconds

1.0.2856.104 (FastSubject) – 0.12 seconds

1.0 Stable – 0.04 seconds


The performance increase is due to two factors. As Wes & Bart explained in their latest video, they have removed the responsibility of scheduling from the subject implementations. This accounts for the improvement between 2698 & the 2856 FastSubject. The next improvement is due to the reduction in memory allocation. Subject’s used to make a copy of the observers array, before exiting the lock and publishing the notification to all the observers. This has been replaced with an immutable list that can be safely access outside of the lock. This immutable list is replaced wholesale when observers subscribe/unsubscribe. Throughput is more important than the subscribe & unsubscribe operations. This make sense if you think about it, its really just how multicast delegate work. Hmmm, more improvements to come?



Also discussed in the video, are the changes to the IScheduler interface. I’m testing the scenario where we want to adapt and enumerable into an observable using the NewThreadScheduler.

var sw = Stopwatch.StartNew();
Enumerable.Range(1, 10000)


1.0.2856.104 – 3.43 seconds

v1.0 Stable – 0.14 seconds


The reason for this gain is pretty simple. The old scheduling API didn’t provide the action that was being executed any contextual information about the thread is was running on. This meant that for NewThreadScheduler to work properly, ToObservable would have had to been hard wired to create a dedicated event loop when the caller subscribes. But that would fly against the whole idea of parameterising concurrency. The IScheduler interface has been overhauled to accommodate scenarios like this.


public interface IScheduler
    IDisposable Schedule(Action action);
    IDisposable Schedule(Action action, TimeSpan dueTime);
    DateTimeOffset Now { get; }


public interface IScheduler
    IDisposable Schedule<TState>(TState state, Func<IScheduler, TState, IDisposable> action);
    IDisposable Schedule<TState>(TState state, DateTimeOffset dueTime, Func<IScheduler, TState, IDisposable> action);
    IDisposable Schedule<TState>(TState state, TimeSpan dueTime, Func<IScheduler, TState, IDisposable> action);
    DateTimeOffset Now { get; }

Don’t panic, you probably won’t ever need to implement this guy, and extension methods allow you to keep using the old API (which I really like!), for example;

Scheduler.NewThread.Scheduler(() => DoStuff());



This wasn’t discussed in the video but I thought it was worth mentioning. ObserverOn has been redesigned so that it makes use of the SchedulerObserver<T>. I always found it strange that this serialization code was duplicated. They’ve addressed that. Shame SchedulerObserver<T> has not been made public though. I think it would be a useful building block for people building their own operators. Anyway, the test code;

var sw = Stopwatch.StartNew();


1.0.2856.104 – 0.8 seconds

v1.0 Stable – 0.2 seconds


I can’t help but feel that there is still more we can squeeze out of ObserveOn. I’ve been playing around with some alternate APIs for this. They will probably find their way into Rxx shortly. More on this soon.



The last few builds have yielded some great improvements, an I’m sure there are more to come. If you run into any performance issues I’d encourage you to hit to forums. More soon.

Rx Official Release (more…)

Reactive Extensions: It’s Official & Interactive Extensions Returns!

Yay! Version 1.0 of Reactive Extensions has just been officially released!

Additionally an Interactive Extensions (Ix) is now package separately its own experimental release!

Nirvana 6 is out – now with Reactive Extensions

my-Channels Nirvana 6 has just been released:

It comes with out of the box Reactive Extensions:


Get every new post delivered to your Inbox.