Summary

In this chapter, we learned how to perform stream based processing in a reactive manner. You now have a better understanding of the core Reactive Streams components, and how they fit together to build data processing flows. You also understand how Akka Streams builds upon the Reactive Streams initiative to allow you to build back-pressure aware data flows and graphs. Lastly, we used this new found knowledge to enhance the streams based processing used in our CQRS and Persistence Query oriented components.

Now that we have a solid understanding of Akka Streams, it's time to think about replacing our HTTP libraries (Unfiltered and Dispatch) with something that's more stream oriented and back-pressure aware. Thankfully, Akka provides that exact functionality via Akka HTTP, which is built on top of Akka Streams. This work will be the primary focus of the next chapter.