()
| 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 { |
nothing calls this directly
no test coverage detected