File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -100,7 +100,6 @@ impl<Q: MessageQueue> BundleQueuePublisher<Q> {
100100 }
101101}
102102
103-
104103#[ cfg( test) ]
105104mod tests {
106105 use super :: * ;
@@ -132,11 +131,17 @@ mod tests {
132131 let bundle_hash = & accepted_bundle. bundle_hash ( ) ;
133132
134133 let start = Instant :: now ( ) ;
135- let result = publisher. publish_raw ( "tips-ingress-rpc" , bundle_hash. to_string ( ) . as_str ( ) , & serde_json:: to_vec ( & accepted_bundle) . unwrap ( ) ) . await ;
134+ let result = publisher
135+ . publish_raw (
136+ "tips-ingress-rpc" ,
137+ bundle_hash. to_string ( ) . as_str ( ) ,
138+ & serde_json:: to_vec ( & accepted_bundle) . unwrap ( ) ,
139+ )
140+ . await ;
136141 let elapsed = start. elapsed ( ) ;
137142
138143 // the backoff tries at minimum 100ms, so verify we tried at least once
139144 assert ! ( result. is_err( ) ) ;
140145 assert ! ( elapsed >= Duration :: from_millis( 100 ) ) ;
141146 }
142- }
147+ }
You can’t perform that action at this time.
0 commit comments