. add collectors for stream test