Akka + RxJava