Implement as a transform stream