fix when source stream emits more than 1 chunk