extract util for better unit-testing TweetCollectorFlowlet