Integrating Akka Streams to Play Application

In this chapter, we will discuss Akka Dynamic Streams components, MergeHub, BroadcastHub, and PartitionHub in detail with some simple examples. Dynamic Streams allow us to execute an Akka Stream's component multiple times, based on our requirements; this is not possible with Basic Akka Static Streams components (discussed in Chapter 7, Working with Reactive Streams).

Once we are comfortable with Akka Dynamic Streams components, we will design a Reactive Chat Application graph using both Akka Static and Dynamic Streams components. We will understand how to use Dynamic Streams components to implement our application.

We will develop a Reactive Chatting System using Scala, Play Framework, Web Socket, Akka Streams API, SBT, and so on.

Finally, we will discuss the Akka Persistence Query API with some simple examples. We will use a similar...