refactored StreamingCorpus and CollapsedLDACorpus and also tests