@@ -44,7 +44,7 @@ async fn call_reducer(module: &ModuleHandle, reducer: &str, args: &str, request_
44
44
r#"{{
45
45
"CallReducer": {{
46
46
"reducer_id": {reducer_id},
47
- "args": {args},
47
+ "args": " {args}" ,
48
48
"request_id": {request_id},
49
49
"flags": 0
50
50
}}
@@ -65,8 +65,8 @@ fn test_calling_a_reducer_in_module(module_name: &'static str) {
65
65
|module| async move {
66
66
call_reducer ( & module, "add" , r#"[\"Tyrion\", 24]"# , 0 ) . await ;
67
67
call_reducer ( & module, "add" , r#"[\"Cersei\", 31]"# , 1 ) . await ;
68
- call_reducer ( & module, "say_hello" , r# "[]"# , 2 ) . await ;
69
- call_reducer ( & module, "list_over_age" , r# "[30]"# , 3 ) . await ;
68
+ call_reducer ( & module, "say_hello" , "[]" , 2 ) . await ;
69
+ call_reducer ( & module, "list_over_age" , "[30]" , 3 ) . await ;
70
70
assert_eq ! (
71
71
read_logs( & module) . await ,
72
72
[
@@ -254,7 +254,7 @@ fn test_index_scans() {
254
254
}
255
255
256
256
async fn bench_call < ' a > ( module : & ModuleHandle , call : & str , count : & u32 ) -> Duration {
257
- let args = format ! ( r# "[{count}]"# ) ;
257
+ let args = format ! ( "[{count}]" ) ;
258
258
let now = Instant :: now ( ) ;
259
259
call_reducer ( module, call, & args, 0 ) . await ;
260
260
now. elapsed ( )
0 commit comments