UNIX style data flow processing