From b0631921d37480c9d737be1422512d827e3d2400 Mon Sep 17 00:00:00 2001
From: Sik Yoon <younxxxx@gmail.com>
Date: Thu, 3 Aug 2023 00:01:57 +0900
Subject: [PATCH] Change parameter type

---
 src/value_estimation_team/indicators/rsi.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/value_estimation_team/indicators/rsi.rs b/src/value_estimation_team/indicators/rsi.rs
index 83f78e9..6551c83 100644
--- a/src/value_estimation_team/indicators/rsi.rs
+++ b/src/value_estimation_team/indicators/rsi.rs
@@ -29,7 +29,7 @@ pub async fn rsi(
     rsi_number: usize,
     input_rt_data: &Vec<(String, Vec<RealtimePriceData>)>,
     output_rsi_data: &mut Vec<(String, Vec<RsiData>)>,
-    valid_usdt_trades: &Vec<String>,
+    filtered_symbols: &Vec<(String, i64)>,
 ) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     let instant = Instant::now();
 
@@ -45,11 +45,11 @@ pub async fn rsi(
     let mut rsi_data_wrapper: Vec<(String, Vec<RsiData>)> = Vec::new();
     let mut rsi_data_vec: Vec<RsiData> = Vec::new();
     let mut rsi_data = RsiData::new();
-    for symbol in valid_usdt_trades {
+    for symbol in filtered_symbols {
         read_data_vec.clear();
         read_price_buffer.clear();
         rsi_data_vec.clear();
-        let symbol_search_result = input_rt_data.iter().position(|x| x.0 == *symbol);
+        let symbol_search_result = input_rt_data.iter().position(|x| x.0 == *symbol.0);
         match symbol_search_result {
             Some(T) => {
                 if input_rt_data[T].1.len() < rsi_number + 1 {
@@ -138,7 +138,7 @@ pub async fn rsi(
                         rsi_data.close_time = buffer.last().unwrap().close_time;
                         rsi_data_vec.push(rsi_data.clone());
                     }
-                    rsi_data_wrapper.push((symbol.clone(), rsi_data_vec.clone()));
+                    rsi_data_wrapper.push((symbol.0.clone(), rsi_data_vec.clone()));
                 }
             }
             None => {}