diff --git a/tests/test_compression.rs b/tests/test_compression.rs index 825e951..206c7f5 100644 --- a/tests/test_compression.rs +++ b/tests/test_compression.rs @@ -47,19 +47,22 @@ async fn check(client: Client) { #[common::named] #[tokio::test] async fn none() { - check(common::prepare_database!().with_compression(Compression::None)).await; + let client = common::prepare_database!().with_compression(Compression::None); + check(client).await; } #[cfg(feature = "lz4")] #[common::named] #[tokio::test] async fn lz4() { - check(common::prepare_database!().with_compression(Compression::Lz4)).await; + let client = common::prepare_database!().with_compression(Compression::Lz4); + check(client).await; } #[cfg(feature = "lz4")] #[common::named] #[tokio::test] async fn lz4_hc() { - check(common::prepare_database!().with_compression(Compression::Lz4Hc(4))).await; + let client = common::prepare_database!().with_compression(Compression::Lz4Hc(4)); + check(client).await; } diff --git a/tests/test_cursor_error.rs b/tests/test_cursor_error.rs index e8ee570..2f1b85a 100644 --- a/tests/test_cursor_error.rs +++ b/tests/test_cursor_error.rs @@ -5,13 +5,15 @@ mod common; #[common::named] #[tokio::test] async fn deferred() { - max_execution_time(common::prepare_database!(), false).await; + let client = common::prepare_database!(); + max_execution_time(client, false).await; } #[common::named] #[tokio::test] async fn wait_end_of_query() { - max_execution_time(common::prepare_database!(), true).await; + let client = common::prepare_database!(); + max_execution_time(client, true).await; } async fn max_execution_time(mut client: Client, wait_end_of_query: bool) {