initial code commit
removed concurrent stream - it's unclear if it is useful