Node's Stream API provides a stream.Transform class for easily and intuitively transforming incoming data. Piping streams through this class preserves natively provided back-pressure and high watermarking, while also keeping you working in the same paradigm (streams!) from start to finish.