|
|
@@ -35,11 +35,12 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
|
|
|
if response.code == 200 {
|
|
|
let data = response.data.as_array().unwrap();
|
|
|
for info in data {
|
|
|
- let symbol = info["market"].as_str().unwrap().to_string().replace("USDT", "_USDT");
|
|
|
+ let s = info["market"].as_str().unwrap();
|
|
|
+ if !s.ends_with("USDT") { continue; }
|
|
|
+ let symbol = s.to_string().replace("USDT", "_USDT");
|
|
|
symbols.push(symbol)
|
|
|
}
|
|
|
}
|
|
|
- info!(?symbols);
|
|
|
|
|
|
for chunk in symbols.chunks(20) {
|
|
|
let ws_name = name.to_string();
|