Update Reactive Programming using RxJava and Akka