Makes streams emit progress events against some goal