Akka Streams is a well-known Reactive Streams implementation that helps you build asynchronous, data-intensive applications with no predetermined data volumes. But how would you leverage its full power to design complex, Akka-backed reactive pipelines? At HomeAway.com we devised an approach to tackle this problem, combining elements of Domain-Driven Design with the abstraction power of the Akka Streams model. In this talk we’ll present our approach by example, discussing useful patterns to
- reason about your streaming application and identify its building blocks
- type-drive the implementation
- handle failure
- instrument your application for logging and monitoring purposes