Streaming API collector added