fix(stream): reads should emit the dataset number for each dataset

fix(stream): reads should emit the dataset number for each dataset #55