()
| 2442 | |
| 2443 | #[tokio::test] |
| 2444 | async fn register_deregister() -> Result<()> { |
| 2445 | let tmp_dir = TempDir::new()?; |
| 2446 | let partition_count = 4; |
| 2447 | let ctx = create_ctx(&tmp_dir, partition_count).await?; |
| 2448 | |
| 2449 | let provider = test::create_table_dual(); |
| 2450 | ctx.register_table("dual", provider)?; |
| 2451 | |
| 2452 | assert!(ctx.deregister_table("dual")?.is_some()); |
| 2453 | assert!(ctx.deregister_table("dual")?.is_none()); |
| 2454 | |
| 2455 | Ok(()) |
| 2456 | } |
| 2457 | |
| 2458 | #[tokio::test] |
| 2459 | async fn send_context_to_threads() -> Result<()> { |
nothing calls this directly
no test coverage detected
searching dependent graphs…