An adoption of the map-reduce paradigm based on the concept of coroutines to the world of stream data processing. - View it on GitHub