1313//
1414
1515// Scenario 6
16- // R
16+ // R
1717// P P P P P P P P P
1818
1919use std:: time:: Duration ;
@@ -50,11 +50,13 @@ async fn test_regions_scenario6_order1_putsub() {
5050
5151 let z9100 = ztimeout ! ( Node :: new( Router , "61aa9100" )
5252 . listen( "tcp/0.0.0.0:0" )
53- . gateway( "{south:[
53+ . gateway(
54+ "{south:[
5455 {filters:[{region_names:[\" region1\" ]}]},
5556 {filters:[{region_names:[\" region2\" ]}]},
5657 {filters:[{region_names:[\" region3\" ]}]}
57- ]}" )
58+ ]}"
59+ )
5860 . open( ) ) ;
5961
6062 let z9110 = ztimeout ! ( Node :: new( Peer , "61aa9110" )
@@ -162,11 +164,13 @@ async fn test_regions_scenario6_order1_pubsub() {
162164
163165 let z9100 = ztimeout ! ( Node :: new( Router , "61ab9100" )
164166 . listen( "tcp/0.0.0.0:0" )
165- . gateway( "{south:[
167+ . gateway(
168+ "{south:[
166169 {filters:[{region_names:[\" region1\" ]}]},
167170 {filters:[{region_names:[\" region2\" ]}]},
168171 {filters:[{region_names:[\" region3\" ]}]}
169- ]}" )
172+ ]}"
173+ )
170174 . open( ) ) ;
171175
172176 let z9110 = ztimeout ! ( Node :: new( Peer , "61ab9110" )
@@ -284,11 +288,13 @@ async fn test_regions_scenario6_order1_getque() {
284288
285289 let z9100 = ztimeout ! ( Node :: new( Router , "61ac9100" )
286290 . listen( "tcp/0.0.0.0:0" )
287- . gateway( "{south:[
291+ . gateway(
292+ "{south:[
288293 {filters:[{region_names:[\" region1\" ]}]},
289294 {filters:[{region_names:[\" region2\" ]}]},
290295 {filters:[{region_names:[\" region3\" ]}]}
291- ]}" )
296+ ]}"
297+ )
292298 . open( ) ) ;
293299
294300 let z9110 = ztimeout ! ( Node :: new( Peer , "61ac9110" )
@@ -390,11 +396,13 @@ async fn test_regions_scenario6_order1_queque() {
390396
391397 let z9100 = ztimeout ! ( Node :: new( Router , "61ad9100" )
392398 . listen( "tcp/0.0.0.0:0" )
393- . gateway( "{south:[
399+ . gateway(
400+ "{south:[
394401 {filters:[{region_names:[\" region1\" ]}]},
395402 {filters:[{region_names:[\" region2\" ]}]},
396403 {filters:[{region_names:[\" region3\" ]}]}
397- ]}" )
404+ ]}"
405+ )
398406 . open( ) ) ;
399407
400408 let z9110 = ztimeout ! ( Node :: new( Peer , "61ad9110" )
@@ -506,11 +514,13 @@ async fn test_regions_scenario6_order1_toksub() {
506514
507515 let z9100 = ztimeout ! ( Node :: new( Router , "61ae9100" )
508516 . listen( "tcp/0.0.0.0:0" )
509- . gateway( "{south:[
517+ . gateway(
518+ "{south:[
510519 {filters:[{region_names:[\" region1\" ]}]},
511520 {filters:[{region_names:[\" region2\" ]}]},
512521 {filters:[{region_names:[\" region3\" ]}]}
513- ]}" )
522+ ]}"
523+ )
514524 . open( ) ) ;
515525
516526 let z9110 = ztimeout ! ( Node :: new( Peer , "61ae9110" )
@@ -622,4 +632,4 @@ async fn test_regions_scenario6_order1_toksub() {
622632 }
623633 }
624634 } ) ;
625- }
635+ }
0 commit comments