diff --git a/tests/integration.rs b/tests/integration.rs
index fef72040..44f5780d 100644
--- a/tests/integration.rs
+++ b/tests/integration.rs
@@ -2628,7 +2628,7 @@ async fn subscribe(
         .await
         .unwrap();
 
-    let msg = tokio::time::timeout(std::time::Duration::from_secs(5), async {
+    let msg = tokio::time::timeout(std::time::Duration::from_secs(10), async {
         loop {
             let msg = accept_message(rx).await;
             if msg.tag == NOTIFY_SUBSCRIBE_RESPONSE_TAG && msg.topic == response_topic {
@@ -2780,7 +2780,7 @@ async fn watch_subscriptions(
         .await
         .unwrap();
 
-    let msg = tokio::time::timeout(std::time::Duration::from_secs(5), async {
+    let msg = tokio::time::timeout(std::time::Duration::from_secs(10), async {
         loop {
             let msg = accept_message(rx).await;
             if msg.tag == NOTIFY_WATCH_SUBSCRIPTIONS_RESPONSE_TAG && msg.topic == response_topic {
@@ -2851,7 +2851,7 @@ async fn accept_watch_subscriptions_changed(
     relay_ws_client: &relay_client::websocket::Client,
     rx: &mut UnboundedReceiver<RelayClientEvent>,
 ) -> Vec<NotifyServerSubscription> {
-    let msg = tokio::time::timeout(std::time::Duration::from_secs(5), async {
+    let msg = tokio::time::timeout(std::time::Duration::from_secs(10), async {
         loop {
             let msg = accept_message(rx).await;
             if msg.tag == NOTIFY_SUBSCRIPTIONS_CHANGED_TAG
@@ -2939,7 +2939,7 @@ async fn accept_notify_message(
     notify_key: &[u8; 32],
     rx: &mut UnboundedReceiver<RelayClientEvent>,
 ) -> (u64, NotifyMessage) {
-    let msg = tokio::time::timeout(std::time::Duration::from_secs(5), async {
+    let msg = tokio::time::timeout(std::time::Duration::from_secs(10), async {
         loop {
             let msg = accept_message(rx).await;
             if msg.tag == NOTIFY_MESSAGE_TAG && msg.topic == topic_from_key(notify_key) {
@@ -3062,7 +3062,7 @@ async fn update(
     .await;
 
     let response_topic = topic_from_key(&notify_key);
-    let msg = tokio::time::timeout(std::time::Duration::from_secs(5), async {
+    let msg = tokio::time::timeout(std::time::Duration::from_secs(10), async {
         loop {
             let msg = accept_message(rx).await;
             if msg.tag == NOTIFY_UPDATE_RESPONSE_TAG && msg.topic == response_topic {
@@ -3141,7 +3141,7 @@ async fn delete(
     .await;
 
     let response_topic = topic_from_key(&notify_key);
-    let msg = tokio::time::timeout(std::time::Duration::from_secs(5), async {
+    let msg = tokio::time::timeout(std::time::Duration::from_secs(10), async {
         loop {
             let msg = accept_message(rx).await;
             if msg.tag == NOTIFY_DELETE_RESPONSE_TAG && msg.topic == response_topic {
@@ -3509,7 +3509,7 @@ async fn sends_noop(notify_server: &NotifyServerContext) {
         .await
         .unwrap();
 
-    let msg = tokio::time::timeout(std::time::Duration::from_secs(5), async {
+    let msg = tokio::time::timeout(std::time::Duration::from_secs(10), async {
         loop {
             let msg = accept_message(&mut rx).await;
             if msg.tag == NOTIFY_NOOP_TAG && msg.topic == notify_topic {