@@ -577,8 +577,11 @@ mod tests {
577577 use crate :: test_helpers:: * ;
578578
579579 use std:: {
580+ sync:: {
581+ atomic:: { AtomicU64 , Ordering } ,
582+ Arc ,
583+ } ,
580584 time:: { Duration , Instant } ,
581- sync:: { Arc , atomic:: { AtomicU64 , Ordering } } ,
582585 } ;
583586
584587 #[ test]
@@ -641,28 +644,25 @@ mod tests {
641644
642645 let repeat_counter = Arc :: new ( AtomicU64 :: new ( 0 ) ) ;
643646 let repeat_counter_check = Arc :: clone ( & repeat_counter) ;
644- let _repeating_timer = node . create_timer_repeating (
645- Duration :: from_millis ( 1 ) ,
646- move || { repeat_counter. fetch_add ( 1 , Ordering :: AcqRel ) ; } ,
647- ) ?;
647+ let _repeating_timer =
648+ node . create_timer_repeating ( Duration :: from_millis ( 1 ) , move || {
649+ repeat_counter. fetch_add ( 1 , Ordering :: AcqRel ) ;
650+ } ) ?;
648651 assert_eq ! ( node. live_timers( ) . len( ) , 1 ) ;
649652
650653 let oneshot_counter = Arc :: new ( AtomicU64 :: new ( 0 ) ) ;
651654 let oneshot_counter_check = Arc :: clone ( & oneshot_counter) ;
652- let _oneshot_timer = node. create_timer_oneshot (
653- Duration :: from_millis ( 1 )
654- . node_time ( ) ,
655- move || { oneshot_counter. fetch_add ( 1 , Ordering :: AcqRel ) ; } ,
656- ) ?;
655+ let _oneshot_timer =
656+ node. create_timer_oneshot ( Duration :: from_millis ( 1 ) . node_time ( ) , move || {
657+ oneshot_counter. fetch_add ( 1 , Ordering :: AcqRel ) ;
658+ } ) ?;
657659
658660 let oneshot_resetting_counter = Arc :: new ( AtomicU64 :: new ( 0 ) ) ;
659661 let oneshot_resetting_counter_check = Arc :: clone ( & oneshot_resetting_counter) ;
660- let _oneshot_resetting_timer = node. create_timer_oneshot (
661- Duration :: from_millis ( 1 ) ,
662- move |timer : & Timer | {
662+ let _oneshot_resetting_timer =
663+ node. create_timer_oneshot ( Duration :: from_millis ( 1 ) , move |timer : & Timer | {
663664 recursive_oneshot ( timer, oneshot_resetting_counter) ;
664- } ,
665- ) ;
665+ } ) ;
666666
667667 let start = Instant :: now ( ) ;
668668 while start. elapsed ( ) < Duration :: from_millis ( 10 ) {
@@ -681,10 +681,7 @@ mod tests {
681681 Ok ( ( ) )
682682 }
683683
684- fn recursive_oneshot (
685- timer : & Timer ,
686- counter : Arc < AtomicU64 > ,
687- ) {
684+ fn recursive_oneshot ( timer : & Timer , counter : Arc < AtomicU64 > ) {
688685 counter. fetch_add ( 1 , Ordering :: AcqRel ) ;
689686 timer. set_oneshot ( move |timer : & Timer | {
690687 recursive_oneshot ( timer, counter) ;
0 commit comments