RxScala extracted from RxJava