Akka Streams: Interleaving streams with priority

This is a set of examples to demonstrate to make use of Akka Streams built-in stages to achieve interleaving stream behavior to give priority to one lane of data amidst many lanes of data.

There are 2 examples:

• JsonFileStreamingExample.scala is a simple single stream of data which reads JSON data from a static file, parses the data into a Scala case class and renders it to screen. This is present to get you familiar with the project.

• MergePreferredStreamInterleavingExample.scala is the main focus of this project. It demonstrates how to combine multiple Sources together and give priority to a single Source. This could be especially useful if you are trying to combine sources of data coming from batch jobs and real-time data and you would like to give priority to the real-time stream.

Running tests:

You can run tests with:

sbt test

You can check coverage using:

sbt coverage test coverageReport

Contributions and PRs

Please feel free to contribute by sending a Pull Request or filing an issue.