From d86b77ab56f530dc288c471ea9ec30f844be70f2 Mon Sep 17 00:00:00 2001
From: Matthew Esposito <matt@matthew.science>
Date: Fri, 29 Dec 2023 20:33:43 -0500
Subject: [PATCH] Reset test threads to 1 (should fix test issues in GHA)

---
 src/client.rs    | 6 +++---
 src/oauth.rs     | 8 ++++----
 src/subreddit.rs | 2 +-
 src/user.rs      | 2 +-
 4 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/client.rs b/src/client.rs
index fd46d15..9a060c9 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -354,13 +354,13 @@ pub async fn json(path: String, quarantine: bool) -> Result<Value, String> {
 	}
 }
 
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_localization_popular() {
 	let val = json("/r/popular/hot.json?&raw_json=1&geo_filter=GLOBAL".to_string(), false).await.unwrap();
 	assert_eq!("GLOBAL", val["data"]["geo_filter"].as_str().unwrap());
 }
 
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_obfuscated_share_link() {
 	let share_link = "/r/rust/s/kPgq8WNHRK".into();
 	// Correct link without share parameters
@@ -368,7 +368,7 @@ async fn test_obfuscated_share_link() {
 	assert_eq!(canonical_path(share_link).await, Ok(Some(canonical_link)));
 }
 
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_share_link_strip_json() {
 	let link = "/17krzvz".into();
 	let canonical_link = "/r/nfl/comments/17krzvz/rapoport_sources_former_no_2_overall_pick/".into();
diff --git a/src/oauth.rs b/src/oauth.rs
index 2513ff5..0ea1202 100644
--- a/src/oauth.rs
+++ b/src/oauth.rs
@@ -213,21 +213,21 @@ fn choose<T: Copy>(list: &[T]) -> T {
 	*fastrand::choose_multiple(list.iter(), 1)[0]
 }
 
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_oauth_client() {
 	assert!(!OAUTH_CLIENT.read().await.token.is_empty());
 }
 
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_oauth_client_refresh() {
 	OAUTH_CLIENT.write().await.refresh().await.unwrap();
 }
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_oauth_token_exists() {
 	assert!(!OAUTH_CLIENT.read().await.token.is_empty());
 }
 
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_oauth_headers_len() {
 	assert!(OAUTH_CLIENT.read().await.headers_map.len() >= 3);
 }
diff --git a/src/subreddit.rs b/src/subreddit.rs
index 1130c0b..7609c40 100644
--- a/src/subreddit.rs
+++ b/src/subreddit.rs
@@ -444,7 +444,7 @@ async fn subreddit(sub: &str, quarantined: bool) -> Result<Subreddit, String> {
 	})
 }
 
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_fetching_subreddit() {
 	let subreddit = subreddit("rust", false).await;
 	assert!(subreddit.is_ok());
diff --git a/src/user.rs b/src/user.rs
index 7b7610a..8ffc366 100644
--- a/src/user.rs
+++ b/src/user.rs
@@ -130,7 +130,7 @@ async fn user(name: &str) -> Result<User, String> {
 	})
 }
 
-#[tokio::test(flavor = "multi_thread", worker_threads = 8)]
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_fetching_user() {
 	let user = user("spez").await;
 	assert!(user.is_ok());