@@ -25,16 +25,16 @@ async fn live_mode_processes_all_blocks_respecting_block_confirmations() -> anyh
2525
2626 robust_provider. root ( ) . anvil_mine ( Some ( 5 ) , None ) . await ?;
2727
28- assert_next ! ( stream, 1 ..=1 ) ;
29- assert_next ! ( stream, 2 ..=2 ) ;
30- assert_next ! ( stream, 3 ..=3 ) ;
31- assert_next ! ( stream, 4 ..=4 ) ;
32- assert_next ! ( stream, 5 ..=5 ) ;
28+ assert_next ! ( stream, 1 ..=1 , timeout = 10 ) ;
29+ assert_next ! ( stream, 2 ..=2 , timeout = 10 ) ;
30+ assert_next ! ( stream, 3 ..=3 , timeout = 10 ) ;
31+ assert_next ! ( stream, 4 ..=4 , timeout = 10 ) ;
32+ assert_next ! ( stream, 5 ..=5 , timeout = 10 ) ;
3333 let mut stream = assert_empty ! ( stream) ;
3434
3535 robust_provider. root ( ) . anvil_mine ( Some ( 1 ) , None ) . await ?;
3636
37- assert_next ! ( stream, 6 ..=6 ) ;
37+ assert_next ! ( stream, 6 ..=6 , timeout = 10 ) ;
3838 assert_empty ! ( stream) ;
3939
4040 // --- 1 block confirmation ---
@@ -43,16 +43,16 @@ async fn live_mode_processes_all_blocks_respecting_block_confirmations() -> anyh
4343
4444 robust_provider. root ( ) . anvil_mine ( Some ( 5 ) , None ) . await ?;
4545
46- assert_next ! ( stream, 6 ..=6 ) ;
47- assert_next ! ( stream, 7 ..=7 ) ;
48- assert_next ! ( stream, 8 ..=8 ) ;
49- assert_next ! ( stream, 9 ..=9 ) ;
50- assert_next ! ( stream, 10 ..=10 ) ;
46+ assert_next ! ( stream, 6 ..=6 , timeout = 10 ) ;
47+ assert_next ! ( stream, 7 ..=7 , timeout = 10 ) ;
48+ assert_next ! ( stream, 8 ..=8 , timeout = 10 ) ;
49+ assert_next ! ( stream, 9 ..=9 , timeout = 10 ) ;
50+ assert_next ! ( stream, 10 ..=10 , timeout = 10 ) ;
5151 let mut stream = assert_empty ! ( stream) ;
5252
5353 robust_provider. root ( ) . anvil_mine ( Some ( 1 ) , None ) . await ?;
5454
55- assert_next ! ( stream, 11 ..=11 ) ;
55+ assert_next ! ( stream, 11 ..=11 , timeout = 10 ) ;
5656 assert_empty ! ( stream) ;
5757
5858 Ok ( ( ) )
0 commit comments