I've used almost this exact pattern (in Go) for a data normalization system. Considered sharing the code, but "never got around to it". What I built actually closely resembled node.js's streams.
Really convenient when you've got various chains of transformations that need to be combined/reordered/dropped while processing streams of data.
Really convenient when you've got various chains of transformations that need to be combined/reordered/dropped while processing streams of data.