Must return stream from task