()
| 445 | |
| 446 | #[tokio::test] |
| 447 | async fn on_error_opening_fail() -> Result<()> { |
| 448 | let result = FileStreamTest::new() |
| 449 | .with_records(vec![make_partition(3), make_partition(2)]) |
| 450 | .with_num_files(2) |
| 451 | .with_on_error(OnError::Fail) |
| 452 | .with_open_errors(vec![1]) |
| 453 | .result() |
| 454 | .await; |
| 455 | |
| 456 | assert!(result.is_err()); |
| 457 | |
| 458 | Ok(()) |
| 459 | } |
| 460 | |
| 461 | #[tokio::test] |
| 462 | async fn on_error_scanning() -> Result<()> { |
nothing calls this directly
no test coverage detected
searching dependent graphs…