@@ -1073,7 +1073,7 @@ pub mod tests {
1073
1073
// Process the waiting job.
1074
1074
p2p_server1. listen_next ( ) . await ;
1075
1075
1076
- tokio:: time:: sleep ( Duration :: from_millis ( 200 ) ) . await ;
1076
+ tokio:: time:: sleep ( Duration :: from_millis ( 300 ) ) . await ;
1077
1077
1078
1078
let evt = receive_event ( & mut p2p_server2, "Should be a TestMessage event" ) . await ?;
1079
1079
@@ -1100,7 +1100,7 @@ pub mod tests {
1100
1100
// Process the waiting job.
1101
1101
p2p_server1. listen_next ( ) . await ;
1102
1102
1103
- tokio:: time:: sleep ( Duration :: from_millis ( 200 ) ) . await ;
1103
+ tokio:: time:: sleep ( Duration :: from_millis ( 300 ) ) . await ;
1104
1104
1105
1105
let evt = receive_event ( & mut p2p_server2, "Should be a TestMessage event" ) . await ?;
1106
1106
@@ -1127,7 +1127,7 @@ pub mod tests {
1127
1127
// Process the waiting job.
1128
1128
p2p_server2. listen_next ( ) . await ;
1129
1129
1130
- tokio:: time:: sleep ( Duration :: from_millis ( 200 ) ) . await ;
1130
+ tokio:: time:: sleep ( Duration :: from_millis ( 300 ) ) . await ;
1131
1131
1132
1132
let evt = receive_event ( & mut p2p_server1, "Should be a TestMessage event" ) . await ?;
1133
1133
@@ -1154,7 +1154,7 @@ pub mod tests {
1154
1154
// Process the waiting job.
1155
1155
p2p_server2. listen_next ( ) . await ;
1156
1156
1157
- tokio:: time:: sleep ( Duration :: from_millis ( 200 ) ) . await ;
1157
+ tokio:: time:: sleep ( Duration :: from_millis ( 300 ) ) . await ;
1158
1158
1159
1159
let evt = receive_event ( & mut p2p_server1, "Should be a TestMessage event" ) . await ?;
1160
1160
0 commit comments