Make intermediate key/value processing into stream

[mutaphore]

Instead of buffering intermediate values in memory while map/reduce functions are applied, use the Transform stream instead for better memory efficiency.