This belongs to a project series I created to lean and create concurrency apps that need streaming features.
I'm simulating a data streaming app
that produces realtime data from any sensor hardware
where this application will handle it using Reactor
and Lightweight Threads
.
gradle run
See also a Kotlin version of the same project -> here