I expand on these concepts in my ScalaDays presentation in Berlin [https://www.youtube.com/watch?v=ilhImUjF53A] and New York [https://www.youtube.com/watch?v=hpQJLQ_8N1c]. I have been using the Akka Streams API [http://doc.akka.io/docs/akka/2.4.16/scala/stream/stream-introduction.html]