def test_read_all_from_avro_many_single_files(self):
    path1 = self._write_data()
    path2 = self._write_data()
    path3 = self._write_data()
    with TestPipeline() as p:
        assert_that(((p | Create([path1, path2, path3])) | avroio.ReadAllFromAvro(use_fastavro=self.use_fastavro)), equal_to((self.RECORDS * 3)))
def test_read_all_from_avro_many_single_files(self):
    path1 = self._write_data()
    path2 = self._write_data()
    path3 = self._write_data()
    with TestPipeline() as p:
        assert_that(((p | Create([path1, path2, path3])) | avroio.ReadAllFromAvro(use_fastavro=self.use_fastavro)), equal_to((self.RECORDS * 3)))