feat: support hstream:// prefix url (#145)

s12f · web-flow · commit 5ce4dc05fd46 · 2022-10-14T11:16:01.000+08:00
diff --git a/client/src/main/java/io/hstream/impl/HStreamClientBuilderImpl.java b/client/src/main/java/io/hstream/impl/HStreamClientBuilderImpl.java
@@ -75,6 +75,11 @@ public HStreamClient build() {
   }
 
   private List<String> parseServerUrls(String url) {
-    return List.of(url.strip().split(","));
+    var prefix = "hstream://";
+    String uriStr = url.strip();
+    if (uriStr.startsWith(prefix)) {
+      uriStr = uriStr.substring(prefix.length());
+    }
+    return List.of(uriStr.split(","));
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -75,6 +75,11 @@ public HStreamClient build() {`
`75`	`75`	`}`
`76`	`76`
`77`	`77`	`private List<String> parseServerUrls(String url) {`
`78`		`- return List.of(url.strip().split(","));`
	`78`	`+ var prefix = "hstream://";`
	`79`	`+ String uriStr = url.strip();`
	`80`	`+ if (uriStr.startsWith(prefix)) {`
	`81`	`+ uriStr = uriStr.substring(prefix.length());`
	`82`	`+ }`
	`83`	`+ return List.of(uriStr.split(","));`
`79`	`84`	`}`
`80`	`85`	`}`