Added test.

tests/it/io/avro/mod.rs

@@ -1,3 +1,5 @@
 //! Read and write from and to Apache Avro
 
 mod read;
+#[cfg(feature = "io_avro_async")]
+mod read_async;

tests/it/io/avro/read/mod.rs → tests/it/io/avro/read.rs

@@ -82,7 +82,7 @@ fn schema() -> (AvroSchema, Schema) {
     (AvroSchema::parse_str(raw_schema).unwrap(), schema)
 }
 
-fn write(codec: Codec) -> Result<(Vec<u8>, RecordBatch)> {
+pub(super) fn write(codec: Codec) -> Result<(Vec<u8>, RecordBatch)> {
     let (avro, schema) = schema();
     // a writer needs a schema and something to write to
     let mut writer = Writer::with_codec(&avro, Vec::new(), codec);

tests/it/io/avro/read_async.rs

@@ -0,0 +1,23 @@
+use avro_rs::Codec;
+
+use arrow2::error::Result;
+use arrow2::io::avro::read;
+
+use super::read::write;
+
+async fn _test_metadata(codec: Codec) -> Result<()> {
+    let (data, expected) = write(codec).unwrap();
+
+    let file = &mut &data[..];
+
+    let (_, schema, _, _) = read::read_metadata(file)?;
+
+    assert_eq!(&schema, expected.schema().as_ref());
+
+    Ok(())
+}
+
+#[tokio::test]
+async fn read_metadata() -> Result<()> {
+    _test_metadata(Codec::Null).await
+}