Using RxJava for asyncpolling, added Akka Actors for in and out pins