[streaming] Added clousure cleaning to streaming