makes use of Akka IO pipelines