Return the stream for each task