def METHOD_NAME(self) -> None:
    datapipes = [_DummyDataReader(1000, str(idx)) for idx in range(10)]
    all_res = []
    num_workers = 4
    for idx in range(num_workers):
        with patch("torchrec.datasets.utils.get_worker_info") as get_worker_info:
            get_worker_info.return_value = Mock(id=idx, num_workers=num_workers)
            all_res += list(ParallelReadConcat(*datapipes))
    expected_res = []
    for dp in datapipes:
        expected_res += list(dp)
    self.assertEqual(all_res, expected_res)