added creating observables from the Akka Event Stream (quite straightforward)