Reactive extension concurrency changes