A transform stream with concurrent processing