[streaming] Test restructure + added tests for streamrecord and collectors