@@ -1147,8 +1147,16 @@ mod tests {
1147
1147
let keypair = Keypair :: generate ( ) ;
1148
1148
1149
1149
// do a noise handshake
1150
- let ( stream, _peer) =
1151
- noise:: handshake ( stream. inner ( ) , & keypair, Role :: Dialer , 5 , 2 ) . await . unwrap ( ) ;
1150
+ let ( stream, _peer) = noise:: handshake (
1151
+ stream. inner ( ) ,
1152
+ & keypair,
1153
+ Role :: Dialer ,
1154
+ 5 ,
1155
+ 2 ,
1156
+ std:: time:: Duration :: from_secs ( 10 ) ,
1157
+ )
1158
+ . await
1159
+ . unwrap ( ) ;
1152
1160
let stream: NoiseSocket < Compat < TcpStream > > = stream;
1153
1161
1154
1162
// after the handshake, try to negotiate some random protocol instead of yamux
@@ -1197,8 +1205,16 @@ mod tests {
1197
1205
1198
1206
// do a noise handshake
1199
1207
let keypair = Keypair :: generate ( ) ;
1200
- let ( stream, _peer) =
1201
- noise:: handshake ( stream. inner ( ) , & keypair, Role :: Listener , 5 , 2 ) . await . unwrap ( ) ;
1208
+ let ( stream, _peer) = noise:: handshake (
1209
+ stream. inner ( ) ,
1210
+ & keypair,
1211
+ Role :: Listener ,
1212
+ 5 ,
1213
+ 2 ,
1214
+ std:: time:: Duration :: from_secs ( 10 ) ,
1215
+ )
1216
+ . await
1217
+ . unwrap ( ) ;
1202
1218
let stream: NoiseSocket < Compat < TcpStream > > = stream;
1203
1219
1204
1220
// after the handshake, try to negotiate some random protocol instead of yamux
@@ -1263,8 +1279,16 @@ mod tests {
1263
1279
1264
1280
// do a noise handshake
1265
1281
let keypair = Keypair :: generate ( ) ;
1266
- let ( stream, _peer) =
1267
- noise:: handshake ( stream. inner ( ) , & keypair, Role :: Dialer , 5 , 2 ) . await . unwrap ( ) ;
1282
+ let ( stream, _peer) = noise:: handshake (
1283
+ stream. inner ( ) ,
1284
+ & keypair,
1285
+ Role :: Dialer ,
1286
+ 5 ,
1287
+ 2 ,
1288
+ std:: time:: Duration :: from_secs ( 10 ) ,
1289
+ )
1290
+ . await
1291
+ . unwrap ( ) ;
1268
1292
let _stream: NoiseSocket < Compat < TcpStream > > = stream;
1269
1293
1270
1294
tokio:: time:: sleep ( std:: time:: Duration :: from_secs ( 60 ) ) . await ;
@@ -1308,8 +1332,16 @@ mod tests {
1308
1332
1309
1333
// do a noise handshake
1310
1334
let keypair = Keypair :: generate ( ) ;
1311
- let ( stream, _peer) =
1312
- noise:: handshake ( stream. inner ( ) , & keypair, Role :: Listener , 5 , 2 ) . await . unwrap ( ) ;
1335
+ let ( stream, _peer) = noise:: handshake (
1336
+ stream. inner ( ) ,
1337
+ & keypair,
1338
+ Role :: Listener ,
1339
+ 5 ,
1340
+ 2 ,
1341
+ std:: time:: Duration :: from_secs ( 10 ) ,
1342
+ )
1343
+ . await
1344
+ . unwrap ( ) ;
1313
1345
let _stream: NoiseSocket < Compat < TcpStream > > = stream;
1314
1346
1315
1347
tokio:: time:: sleep ( std:: time:: Duration :: from_secs ( 60 ) ) . await ;
0 commit comments