MCPcopy Create free account
hub / github.com/apache/avro-rs / test_reader_iterator

Function test_reader_iterator

avro/src/reader/mod.rs:245–264  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

243
244 #[test]
245 fn test_reader_iterator() -> TestResult {
246 let schema = Schema::parse_str(SCHEMA)?;
247 let reader = Reader::builder(ENCODED).reader_schema(&schema).build()?;
248
249 let mut record1 = Record::new(&schema).unwrap();
250 record1.put("a", 27i64);
251 record1.put("b", "foo");
252
253 let mut record2 = Record::new(&schema).unwrap();
254 record2.put("a", 42i64);
255 record2.put("b", "bar");
256
257 let expected = [record1.into(), record2.into()];
258
259 for (i, value) in reader.enumerate() {
260 assert_eq!(value?, expected[i]);
261 }
262
263 Ok(())
264 }
265
266 #[test]
267 fn test_reader_invalid_header() -> TestResult {

Callers

nothing calls this directly

Calls 3

buildMethod · 0.80
reader_schemaMethod · 0.80
putMethod · 0.80

Tested by

no test coverage detected