diff --git a/.config/nextest.toml b/.config/nextest.toml index 202b52aa..5d2bdd6d 100644 --- a/.config/nextest.toml +++ b/.config/nextest.toml @@ -1,5 +1,5 @@ [profile.default] test-threads = 1 fail-fast = false -slow-timeout = { period = "5s", terminate-after = 1 } -retries = { backoff = "fixed", count = 3, delay = "2s" } +slow-timeout = { period = "10s", terminate-after = 1 } +retries = { backoff = "fixed", count = 3, delay = "1s" } diff --git a/src/tests/processing.rs b/src/tests/processing.rs index 0dea7f37..69b016e4 100644 --- a/src/tests/processing.rs +++ b/src/tests/processing.rs @@ -89,12 +89,14 @@ fn buffer_size_is_called_before_process() { |state, _, _| { assert_eq!(*state, "initializing"); *state = "processing"; + // Give the processing thread some time to run, in case it wants to. + std::thread::sleep(std::time::Duration::from_secs(3)); crate::Control::Continue }, ); let ac = client.activate_async((), process_handler).unwrap(); assert!(recv - .recv_timeout(std::time::Duration::from_secs(1)) + .recv_timeout(std::time::Duration::from_secs(5)) .unwrap()); assert_eq!(ac.deactivate().unwrap().2.state, "processing"); }