Use shared test runtime

Cargo.toml

@@ -41,3 +41,4 @@ tokio = { version = "1.37.0", features = ["macros", "test-util", "rt-multi-threa
 axum = "0.7.9"
 svix = "1.42.0"
 http-body-util = "0.1.2"
+tokio-shared-rt = "0.1.0"

src/api_keys.rs

@@ -203,7 +203,7 @@ mod test {
     use crate::types::CreateApiKeyOptions;
     use crate::Result;
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let resend = &*CLIENT;

src/audiences.rs

@@ -170,7 +170,7 @@ mod test {
     use crate::tests::CLIENT;
     use crate::Result;
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let resend = &*CLIENT;

src/broadcasts.rs

@@ -263,7 +263,7 @@ mod test {
         Result,
     };
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn create_send_broadcast() -> Result<()> {
         let resend = &*CLIENT;
@@ -298,7 +298,7 @@ mod test {
         Ok(())
     }
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn list_get_broadcast() -> Result<()> {
         let resend = &*CLIENT;

src/client.rs

@@ -40,7 +40,8 @@ impl Resend {
     ///
     /// [`Resend`]: https://resend.com
     pub fn new(api_key: &str) -> Self {
-        Self::with_client(api_key, ReqwestClient::default())
+        Self::with_client(api_key, ReqwestClient::builder().pool_max_idle_per_host(0).build().unwrap())
+        // Self::with_client(api_key, ReqwestClient::default())
     }
 
     /// Creates a new [`Resend`] client with a provided [`reqwest::Client`].

src/contacts.rs

@@ -302,7 +302,7 @@ mod test {
     use crate::types::{ContactChanges, ContactData};
     use crate::Result;
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let resend = &*CLIENT;

src/domains.rs

@@ -395,7 +395,7 @@ mod test {
         Result,
     };
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let resend = &*CLIENT;

src/emails.rs

@@ -484,7 +484,7 @@ mod test {
     use crate::{tests::CLIENT, Result};
     use jiff::{Span, Timestamp, ToSpan, Zoned};
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let from = "Acme <[email protected]>";
@@ -582,7 +582,7 @@ mod test {
         Ok(())
     }
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn schedule_email() -> Result<()> {
         let now_plus_1h = Zoned::now()

src/rate_limit.rs

@@ -209,7 +209,7 @@ mod tests {
     use super::{send_with_retry_opts, RetryOptions};
     use crate::Error;
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn test_retry_count_err() {
         let mut run_count = 0u32;
@@ -242,7 +242,7 @@ mod tests {
         assert!(run_count == 0);
     }
 
-    #[tokio::test]
+    #[tokio_shared_rt::test(shared = true)]
     #[cfg(not(feature = "blocking"))]
     async fn test_retry_count_ok() {
         let mut retry_count = 0u32;