async def METHOD_NAME(self):
    correct = 0
    nitems = 10
    for iexample, (writer_schema, datum) in enumerate(SCHEMAS_TO_VALIDATE):
        for codec in CODECS_TO_VALIDATE:
            file_path = os.path.join(AvroReaderTestsAsync._samples_dir_root, 'test_' + codec + '_' + str(iexample) + '.avro')
            with open(file_path, 'rb') as reader:
                datum_reader = AsyncDatumReader()
                async_reader = AsyncBufferedReaderWrapper(reader)
                async with await AsyncDataFileReader(async_reader, datum_reader).init() as dfr:
                    round_trip_data = []
                    async for x in dfr:
                        round_trip_data.append(x)
                    if ([datum] * nitems) == round_trip_data:
                        correct += 1
    self.assertEqual(correct, len(CODECS_TO_VALIDATE) * len(SCHEMAS_TO_VALIDATE))