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