Reactive Streams are the key to build asynchronous, data-intensive applications with no predetermined data volumes. Akka Streams is a well-known Reactive Streams implementation offering a powerful DSL to build complex, Akka-backed reactive pipelines.
At HomeAway we devised an approach to roll out reactive data pipelines, by combining elements of Domain-Driven Design with the abstraction power of the Akka Streams model.
In this talk we’ll
- briefly introduce Reactive Streams and Akka Streams
- present our approach to pipeline design by example, discussing useful patterns to reason about your streaming application and type-drive its implementation