using newer, less memory intensive version of code from async in stream cleaning

using newer, less memory intensive version of code from async in stream cleaning