I was playing with both akka and rxjava and came across the following post that described how to map rxjava observables from messages posted to akka actors.