Akka Steam Graphs — Dynamic Parallel Streams, Example 3

Background

Please read the link below for the first example and a background

Akka Steam Graphs — A first example

Second Example:

Akka Steam Graphs — Parallel Streams, Example 2

Akka Stream Graphs

From Akka website:

Considering linear Flows to be like roads, we can picture graph operations as junctions: multiple flows being connected at a single point.

Read up on Akka Stream Graphs here:

Working with Graphs * Akka Documentation

Second Graph code example from Akka Site

Understanding the example

Code Modifications

• Added a materializer to run the Graph

final ActorSystem system = ActorSystem.create("QuickStart");
final Materializer materializer = ActorMaterializer.create(system);

• Changed source to print the result

g.run(materializer).forEach(s -> s.thenAccept(System.out::println));

• Add a terminate to stop the run

system.terminate();

Modified Code

Understanding

Parallel Streams two

1. Our Source is has five numbers “N” Strings
2. Then we have a broadcast with N dynamic paths, based on the number of filters
3. We have N flows through the N filters
4. We print on out values

Code Output

ax
bx
cx

Conclusion

Streams are a powerful way to develop modern reactive applications.

Akka Graphs add another powerful layer to stream processing.

What is your opinion ? Please do comment in section below.