@@ -1559,7 +1559,7 @@ mod tests {
15591559 . stream_historical ( BlockNumberOrTag :: Number ( 0 ) , BlockNumberOrTag :: Number ( end_num) ) ;
15601560
15611561 let roerg = async {
1562- sleep ( Duration :: from_millis ( 100 ) ) . await ;
1562+ sleep ( Duration :: from_secs ( 1 ) ) . await ;
15631563 let _ = provider. anvil_mine ( Option :: Some ( 20 ) , Option :: None ) . await ;
15641564 let head_now = provider. get_block_number ( ) . await . unwrap ( ) ;
15651565 let reorg_start = end_num - 5 ;
@@ -1618,8 +1618,6 @@ mod tests {
16181618 let head_block = provider. get_block_by_number ( BlockNumberOrTag :: Latest ) . await ?;
16191619 let end_num = head_block. unwrap ( ) . header ( ) . number ( ) ;
16201620
1621- println ! ( "END NUM {end_num}" ) ;
1622-
16231621 let client = BlockRangeScanner :: new ( )
16241622 . connect_ws :: < Ethereum > ( anvil. ws_endpoint_url ( ) )
16251623 . await ?
@@ -1631,14 +1629,11 @@ mod tests {
16311629 . stream_historical ( BlockNumberOrTag :: Number ( 0 ) , BlockNumberOrTag :: Number ( end_num) ) ;
16321630
16331631 let roerg = async {
1634- sleep ( Duration :: from_millis ( 100 ) ) . await ;
1632+ sleep ( Duration :: from_secs ( 1 ) ) . await ;
16351633 let pre_reorg_mine = 20 ;
16361634 let _ = provider. anvil_mine ( Option :: Some ( pre_reorg_mine) , Option :: None ) . await ;
1637- let head_now = provider. get_block_number ( ) . await . unwrap ( ) ;
16381635 // Reorg back to previous head aka our end num
16391636 let depth = pre_reorg_mine + 1 ;
1640- println ! ( "HEAD {head_now}" ) ;
1641- println ! ( "DEPTH {depth}" ) ;
16421637 let _ = provider. anvil_reorg ( ReorgOptions { depth, tx_block_pairs : vec ! [ ] } ) . await ;
16431638 let _ = provider. anvil_mine ( Option :: Some ( 20 ) , Option :: None ) . await ;
16441639
0 commit comments