RxJava port of ReactiveUI