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

handle each symbol concurrently

Browse source
This commit is contained in:
Paul Campbell 2024-03-31 18:45:03 +01:00
parent 1c302990af
commit 235104ae75
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/main.rs
View file

@ -2,6 +2,7 @@ use async_std::prelude::*;
use chrono::prelude::*; use chrono::prelude::*;
use clap::Parser; use clap::Parser;
use futures::future::try_join_all;
use std::{ use std::{
io::{Error, ErrorKind}, io::{Error, ErrorKind},
time::Duration, time::Duration,
@ -160,9 +161,12 @@ async fn fetch_and_output_symbol_data(
from: DateTime<Utc>, from: DateTime<Utc>,
to: DateTime<Utc>, to: DateTime<Utc>,
) -> std::io::Result<()> { ) -> std::io::Result<()> {
let mut fs = vec![];
for symbol in symbols.split(',') { for symbol in symbols.split(',') {
fetch_and_output_closing_data(symbol, from, to).await?; let f = fetch_and_output_closing_data(symbol, from, to);
fs.push(f);
} }
try_join_all(fs).await?;
Ok(()) Ok(())
} }