Create Reactive Programming using RxJava and Akka