I just blogged about an example flow using GenStage here.
The code is available on GitHub.
7 Likes
why dont it stop? and just carry on and printing the station address?
what benefit that would be?
Maybe because it is a demo of how to process infinite stream