Scala Reactive Programming

Working with Reactive Streams

In this chapter, we will discuss the use of the Akka Streams API to easily perform asynchronous data stream processing with non-blocking backpressure. We will also discuss what the CQRS/ES pattern is and how the Akka Persistence module uses this pattern to support the development of Event-Driven systems or applications.

Its shares the same Akka Toolkit office website (http://akka.io/) and GitHub source code location is available at https://github.com/akka/akka.

In this chapter, you will learn the following concepts:

• Streams and the benefits of streaming data
• Akka Streams and their features and benefits
• How Akka Streams support data streaming
• Backpressure and its importance
• How Akka Streams implements backpressure, ...