Akka streams for high throughput data processing by Zack Loebel-Begelman