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

don't wait before fetching first set of data

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

4
src/main.rs
View file

@ -178,6 +178,10 @@ 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");
// initial data fetch
fetch_and_output_symbol_data(&opts.symbols, from, to).await?;
let mut interval = async_std::stream::interval(Duration::from_secs(30)); let mut interval = async_std::stream::interval(Duration::from_secs(30));
while let Some(_) = interval.next().await { while let Some(_) = interval.next().await {
fetch_and_output_symbol_data(&opts.symbols, from, to).await?; fetch_and_output_symbol_data(&opts.symbols, from, to).await?;