@@ -204,8 +204,8 @@ fn bench_wasm_ping_direct(
204
204
handler
205
205
. ping ( None :: < async_nats:: HeaderMap > )
206
206
. await
207
- . expect ( "failed to call handler" )
208
- } )
207
+ . expect ( "failed to call handler" ) ;
208
+ } ) ;
209
209
} ) ;
210
210
Ok ( ( ) )
211
211
}
@@ -225,7 +225,7 @@ fn bench_wasm_greet_direct(
225
225
. await
226
226
. expect ( "failed to call handler" ) ;
227
227
assert_eq ! ( greeting, "Hello, test" ) ;
228
- } )
228
+ } ) ;
229
229
} ) ;
230
230
Ok ( ( ) )
231
231
}
@@ -272,7 +272,7 @@ where
272
272
. expect ( "failed to send message" ) ;
273
273
assert ! ( status. is_none( ) ) ;
274
274
assert_eq ! ( payload, expect) ;
275
- } )
275
+ } ) ;
276
276
} ) ;
277
277
stop_tx. send ( ( ) ) . expect ( "failed to stop server" ) ;
278
278
rt. block_on ( async { srv. await . context ( "server task panicked" ) ? } ) ?;
@@ -470,7 +470,7 @@ fn bench_wasm_ping_nats_wrpc(
470
470
ping_bindings_wrpc:: wrpc_bench:: bench:: ping:: ping ( & wrpc, None )
471
471
. await
472
472
. expect ( "failed to call `ping`" ) ;
473
- } )
473
+ } ) ;
474
474
} ) ;
475
475
stop_tx. send ( ( ) ) . expect ( "failed to stop server" ) ;
476
476
rt. block_on ( async { srv. await . context ( "server task panicked" ) ? } ) ?;
@@ -522,7 +522,7 @@ fn bench_wasm_greet_nats_wrpc(
522
522
greet_bindings_wrpc:: wrpc_bench:: bench:: greet:: greet ( & wrpc, None , "test" )
523
523
. await
524
524
. expect ( "failed to call `greet`" ) ;
525
- } )
525
+ } ) ;
526
526
} ) ;
527
527
stop_tx. send ( ( ) ) . expect ( "failed to stop server" ) ;
528
528
rt. block_on ( async { srv. await . context ( "server task panicked" ) ? } ) ?;
@@ -568,7 +568,7 @@ fn bench_nats_wrpc_ping(g: &mut BenchmarkGroup<impl Measurement>) -> anyhow::Res
568
568
ping_bindings_wrpc:: wrpc_bench:: bench:: ping:: ping ( & wrpc, None )
569
569
. await
570
570
. expect ( "failed to call `ping`" ) ;
571
- } )
571
+ } ) ;
572
572
} ) ;
573
573
stop_tx. send ( ( ) ) . expect ( "failed to stop server" ) ;
574
574
rt. block_on ( async { srv. await . context ( "server task panicked" ) ? } ) ?;
@@ -615,7 +615,7 @@ fn bench_nats_wrpc_greet(g: &mut BenchmarkGroup<impl Measurement>) -> anyhow::Re
615
615
. await
616
616
. expect ( "failed to call `greet`" ) ;
617
617
assert_eq ! ( greeting, "Hello, test" ) ;
618
- } )
618
+ } ) ;
619
619
} ) ;
620
620
stop_tx. send ( ( ) ) . expect ( "failed to stop server" ) ;
621
621
rt. block_on ( async { srv. await . context ( "server task panicked" ) ? } ) ?;
0 commit comments