This doesn't match that much to Rx.NET but makes sense, I've updated the code.