fix streaming pipe