sync'ed event "parsingFinished" between the 2 streams. Created test for consuming/wait all streamIds