stream piping oriented workflow