updated for seperate streaming for NLP and DM