updated for akka-streams 0.10