Programming streaming patterns on top of akka