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 Scalacase 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 multipleSource
s together and give priority to a singleSource
. 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.
You can run tests with:
sbt test
You can check coverage using:
sbt coverage test coverageReport
Please feel free to contribute by sending a Pull Request or filing an issue.