Extending the Akka Streams HelloWorld example with the Flow component

In this example, we will experiment with the full RunnableGraph, meaning that we will use Flow to connect both Source and Sink. Flow has one input to connect to Source and retrieve incoming data elements. It has one output to connect to Sink and send data elements to it.

We will use the previous HelloWorld example and add a couple of new applications to test different scenarios:

Perform the following steps to understand this example:

1. Create a Akka Streams HelloWorld App with Source | Flow | Sink:

      package com.packt.publishing.akka.streams.hello 
      import akka.actor.ActorSystem 
      import akka.stream.ActorMaterializer 
      import akka.stream.scaladsl.{Flow, Sink, Source} 
 
      object AkkaStreams_Source2Flow2Sink_HelloWorldApp extends App{ 
 
        implicit val actorSystem = ActorSystem(...