Common operations for piped NodeJS streams (V2 preview version)