Skip to content

Commit e9900cf

Browse files
committed
fix: add back timeoute
1 parent ef3b363 commit e9900cf

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

tests/block_range_scanner.rs

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -23,11 +23,11 @@ async fn live_mode_processes_all_blocks_respecting_block_confirmations() -> anyh
2323

2424
robust_provider.root().anvil_mine(Some(5), None).await?;
2525

26-
assert_next!(stream, 1..=1);
27-
assert_next!(stream, 2..=2);
28-
assert_next!(stream, 3..=3);
29-
assert_next!(stream, 4..=4);
30-
assert_next!(stream, 5..=5);
26+
assert_next!(stream, 1..=1, timeout = 10);
27+
assert_next!(stream, 2..=2, timeout = 10);
28+
assert_next!(stream, 3..=3, timeout = 10);
29+
assert_next!(stream, 4..=4, timeout = 10);
30+
assert_next!(stream, 5..=5, timeout = 10);
3131
let mut stream = assert_empty!(stream);
3232

3333
robust_provider.root().anvil_mine(Some(1), None).await?;
@@ -41,11 +41,11 @@ async fn live_mode_processes_all_blocks_respecting_block_confirmations() -> anyh
4141

4242
robust_provider.root().anvil_mine(Some(5), None).await?;
4343

44-
assert_next!(stream, 6..=6);
45-
assert_next!(stream, 7..=7);
46-
assert_next!(stream, 8..=8);
47-
assert_next!(stream, 9..=9);
48-
assert_next!(stream, 10..=10);
44+
assert_next!(stream, 6..=6, timeout = 10);
45+
assert_next!(stream, 7..=7, timeout = 10);
46+
assert_next!(stream, 8..=8, timeout = 10);
47+
assert_next!(stream, 9..=9, timeout = 10);
48+
assert_next!(stream, 10..=10, timeout = 10);
4949
let mut stream = assert_empty!(stream);
5050

5151
robust_provider.root().anvil_mine(Some(1), None).await?;

0 commit comments

Comments
 (0)