refactored StreamingCorpus