fix refactoring

pipe returns a new stream, so old stream needs to be replaced with the new one
remove console.log