RxJava complex test scenario