Cancelled cleaning whole streams entity on each iteration of searching new streams