Attempt at a bridge from RxJava to Akka and vice versa.