Increase default timeout

Author: davidsteiner

crates/hotfix/tests/common/mock_counterparty.rs

@@ -1,3 +1,4 @@
+use crate::common::session_assertions::DEFAULT_TIMEOUT;
 use hotfix::config::SessionConfig;
 use hotfix::message::logon::{Logon, ResetSeqNumConfig};
 use hotfix::message::{FixMessage, RawFixMessage, generate_message};
@@ -12,8 +13,6 @@ use std::time::Duration;
 use tokio::sync::mpsc::Receiver;
 use tokio::sync::{mpsc, oneshot};
 
-const DEFAULT_TIMEOUT: Duration = Duration::from_millis(10);
-
 pub struct MockCounterparty<M> {
     receiver: Receiver<WriterMessage>,
     received_messages: Vec<Message>,

crates/hotfix/tests/common/session_assertions.rs

@@ -2,20 +2,22 @@ use crate::common::test_messages::TestMessage;
 use hotfix::session::{SessionRef, Status};
 use std::time::Duration;
 
+pub const DEFAULT_TIMEOUT: Duration = Duration::from_millis(50);
+
 pub trait SessionAssertions {
     async fn assert_status(&self, expected_status: Status);
     async fn assert_status_with_timeout(&self, expected_status: Status, timeout: Duration);
 }
 
 impl SessionAssertions for SessionRef<TestMessage> {
     async fn assert_status(&self, expected_status: Status) {
-        self.assert_status_with_timeout(expected_status, Duration::from_millis(10))
+        self.assert_status_with_timeout(expected_status, DEFAULT_TIMEOUT)
             .await;
     }
 
     async fn assert_status_with_timeout(&self, expected_status: Status, timeout: Duration) {
         let deadline = tokio::time::Instant::now() + timeout;
-        let retry_interval = Duration::from_millis(1);
+        let retry_interval = Duration::from_millis(5);
 
         let mut session_info = self.get_session_info().await;
         while tokio::time::Instant::now() < deadline {