()
| 625 | |
| 626 | #[tokio::test] |
| 627 | async fn with_limit_between_files() -> Result<()> { |
| 628 | let batches = create_and_collect(Some(5)).await; |
| 629 | #[rustfmt::skip] |
| 630 | assert_batches_eq!(&[ |
| 631 | "+---+", |
| 632 | "| i |", |
| 633 | "+---+", |
| 634 | "| 0 |", |
| 635 | "| 1 |", |
| 636 | "| 2 |", |
| 637 | "| 0 |", |
| 638 | "| 1 |", |
| 639 | "+---+", |
| 640 | ], &batches); |
| 641 | |
| 642 | Ok(()) |
| 643 | } |
| 644 | |
| 645 | #[tokio::test] |
| 646 | async fn with_limit_at_middle_of_batch() -> Result<()> { |
nothing calls this directly
no test coverage detected
searching dependent graphs…