cargo fmt

Author: michaelklishin

tests/list_policies_tests.rs

@@ -35,8 +35,8 @@ fn test_list_policies() -> Result<(), Box<dyn std::error::Error>> {
         "{\"max-length\": 12345}",
     ]);
 
-
-    run_succeeds(["list", "policies"]).stdout(predicate::str::contains(policy_name).and(predicate::str::contains("12345")));
+    run_succeeds(["list", "policies"])
+        .stdout(predicate::str::contains(policy_name).and(predicate::str::contains("12345")));
     run_succeeds(["delete", "policy", "--name", policy_name]);
     run_succeeds(["list", "policies"]).stdout(predicate::str::contains(policy_name).not());
 
@@ -65,13 +65,9 @@ fn test_operator_policies() -> Result<(), Box<dyn std::error::Error>> {
     run_succeeds(["list", "operator_policies"]).stdout(
         predicate::str::contains(operator_policy_name).and(predicate::str::contains("op-foo")),
     );
-    run_succeeds([
-        "delete",
-        "operator_policy",
-        "--name",
-        operator_policy_name,
-    ]);
-    run_succeeds(["list", "operator_policies"]).stdout(predicate::str::contains(operator_policy_name).not());
+    run_succeeds(["delete", "operator_policy", "--name", operator_policy_name]);
+    run_succeeds(["list", "operator_policies"])
+        .stdout(predicate::str::contains(operator_policy_name).not());
 
     Ok(())
 }

tests/list_queues_tests.rs

@@ -34,25 +34,26 @@ fn list_queues() -> Result<(), Box<dyn std::error::Error>> {
     run_succeeds(["declare", "vhost", "--name", vh2]);
 
     // declare a new queue in vhost 1
-    run_succeeds(["-V", vh1, "declare", "queue", "--name", q1, "--type", "classic"]);
+    run_succeeds([
+        "-V", vh1, "declare", "queue", "--name", q1, "--type", "classic",
+    ]);
 
     // declare new queue in vhost 2
-    run_succeeds(["-V", vh2, "declare", "queue", "--name", q2, "--type", "quorum"]);
+    run_succeeds([
+        "-V", vh2, "declare", "queue", "--name", q2, "--type", "quorum",
+    ]);
 
     await_queue_metric_emission();
 
     // list queues in vhost 1
-    run_succeeds(["-V", vh1, "list", "queues"]).stdout(
-        predicate::str::contains(q1).and(predicate::str::contains("new_queue2").not()),
-    );
+    run_succeeds(["-V", vh1, "list", "queues"])
+        .stdout(predicate::str::contains(q1).and(predicate::str::contains("new_queue2").not()));
 
     // delete the queue in vhost 1
     run_succeeds(["-V", vh1, "delete", "queue", "--name", q1]);
 
     // list queues in vhost 1
-    run_succeeds(["-V", vh1, "list", "queues"]).stdout(
-        predicate::str::contains(q1).not()
-    );
+    run_succeeds(["-V", vh1, "list", "queues"]).stdout(predicate::str::contains(q1).not());
 
     delete_vhost(vh1).expect("failed to delete a virtual host");
     delete_vhost(vh2).expect("failed to delete a virtual host");

tests/list_runtime_parameters_tests.rs

@@ -41,7 +41,8 @@ fn test_runtime_parameters() -> Result<(), Box<dyn std::error::Error>> {
         "parameters",
         "--component",
         "federation-upstream",
-    ]).stdout(predicate::str::contains("my-upstream").and(predicate::str::contains("3600000")));
+    ])
+    .stdout(predicate::str::contains("my-upstream").and(predicate::str::contains("3600000")));
 
     run_succeeds([
         "-V",
@@ -61,7 +62,8 @@ fn test_runtime_parameters() -> Result<(), Box<dyn std::error::Error>> {
         "parameters",
         "--component",
         "federation-upstream",
-    ]).stdout(predicate::str::contains("my-upstream").not());
+    ])
+    .stdout(predicate::str::contains("my-upstream").not());
 
     delete_vhost(vh).expect("failed to delete a virtual host");