Moved typed stream utils into PipeUtils