fix(rest) stream.createPipe -> pipe.create