Simplifying streaming applications with Functors

Streaming libraries such as Akka Streams can provide us with a rich toolset to help us process data from disparate systems. As these data pipelines grow in complexity so do the issues around code readability, boilerplate code and the bleeding of different domain concerns within the pipeline.

We’ll look at using Akka Streams and cats to implement Functors which maintain a separation of concerns between data and metadata within the pipeline.

Leave a Reply