format

risingwavelabs · Oct 24, 2023 · 56eb5fc · 56eb5fc
1 parent 76dc616
commit 56eb5fc
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/src/connector/src/common.rs b/src/connector/src/common.rs
@@ -515,11 +515,7 @@ impl NatsCommon {
         let subject_name = self
             .subject
             .replace(',', "-")
-            .replace('.', "_")
-            .replace('>', "_")
-            .replace('*', "_")
-            .replace(' ', "_")
-            .replace('\t', "_");
+            .replace(['.', '>', '*', ' ', '\t'], "_");
         let name = format!("risingwave-consumer-{}-{}", subject_name, split_id);
         let mut config = jetstream::consumer::pull::Config {
             ack_policy: jetstream::consumer::AckPolicy::None,