()
| 430 | |
| 431 | #[tokio::test] |
| 432 | async fn on_error_scanning_fail() -> Result<()> { |
| 433 | let result = FileStreamTest::new() |
| 434 | .with_records(vec![make_partition(3), make_partition(2)]) |
| 435 | .with_num_files(2) |
| 436 | .with_on_error(OnError::Fail) |
| 437 | .with_scan_errors(vec![1]) |
| 438 | .result() |
| 439 | .await; |
| 440 | |
| 441 | assert!(result.is_err()); |
| 442 | |
| 443 | Ok(()) |
| 444 | } |
| 445 | |
| 446 | #[tokio::test] |
| 447 | async fn on_error_opening_fail() -> Result<()> { |
nothing calls this directly
no test coverage detected
searching dependent graphs…