Returning stream from clean task, rather than callback