[streaming] Fixed StreamCollectorTest