From f8e702a462166ebfd9da583eaf651d7dbbb04a9e Mon Sep 17 00:00:00 2001 From: Sik Yoon Date: Sat, 2 Dec 2023 03:02:06 +0900 Subject: [PATCH] Change parameter data type --- src/value_estimation_team/indicators/rsi.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/value_estimation_team/indicators/rsi.rs b/src/value_estimation_team/indicators/rsi.rs index 67d10c7..a7bb93a 100644 --- a/src/value_estimation_team/indicators/rsi.rs +++ b/src/value_estimation_team/indicators/rsi.rs @@ -3,6 +3,7 @@ use crate::database_control::*; use crate::value_estimation_team::datapoints::price_data::RealtimePriceData; +use crate::strategy_team::FilteredData; use csv::{DeserializeRecordsIter, StringRecord}; use futures::future::try_join_all; use serde::Deserialize; @@ -30,7 +31,7 @@ impl RsiData { pub async fn rsi( rsi_number: usize, input_rt_data: &Vec<(String, Vec)>, - filtered_symbols: &Vec<(String, i64)>, + filtered_symbols: &Vec, ) -> Result)>, Box> { let instant = Instant::now(); @@ -41,7 +42,7 @@ pub async fn rsi( for element in filtered_symbols { let element_c = element.clone(); let rsi_data_wrapper_arc_c = Arc::clone(&rsi_data_wrapper_arc); - let symbol_search_result = input_rt_data.iter().position(|x| x.0 == *element_c.0); + let symbol_search_result = input_rt_data.iter().position(|x| x.0 == *element_c.symbol); match symbol_search_result { Some(T) => { let input_rt_data_c = input_rt_data.clone(); @@ -144,7 +145,7 @@ pub async fn rsi( rsi_data_vec.push(rsi_data.clone()); } let mut rsi_data_wrapper_lock = rsi_data_wrapper_arc_c.lock().await; - rsi_data_wrapper_lock.push((element_c.0.clone(), rsi_data_vec.clone())); + rsi_data_wrapper_lock.push((element_c.symbol.clone(), rsi_data_vec.clone())); } })); }