Add concurrency.rx base for future test around Reactive Extensions