kemitix/manning-data-streaming-with-async-rust
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

extract fetch_and_output_closing_data

Browse source
This commit is contained in:
Paul Campbell 2024-03-31 18:30:20 +01:00
parent 15d919e62c
commit fe660459d9
1 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/main.rs
View file

@ -138,6 +138,18 @@ fn output_csv_line(closes: Vec<f64>, from: DateTime<Utc>, symbol: &str) {
); );
} }
async fn fetch_and_output_closing_data(
symbol: &str,
from: DateTime<Utc>,
to: DateTime<Utc>,
) -> std::io::Result<()> {
let closes = fetch_closing_data(&symbol, &from, &to).await?;
if !closes.is_empty() {
output_csv_line(closes, from, symbol);
}
Ok(())
}
#[async_std::main] #[async_std::main]
async fn main() -> std::io::Result<()> { async fn main() -> std::io::Result<()> {
let opts = Opts::parse(); let opts = Opts::parse();
@ -147,10 +159,7 @@ async fn main() -> std::io::Result<()> {
// a simple way to output a CSV header // a simple way to output a CSV header
println!("period start,symbol,price,change %,min,max,30d avg"); println!("period start,symbol,price,change %,min,max,30d avg");
for symbol in opts.symbols.split(',') { for symbol in opts.symbols.split(',') {
let closes = fetch_closing_data(&symbol, &from, &to).await?; fetch_and_output_closing_data(symbol, from, to).await?;
if !closes.is_empty() {
output_csv_line(closes, from, symbol);
}
} }
Ok(()) Ok(())
} }