Struct IndexStream 

pub struct IndexStream;

A stream that yields market index updates at regular intervals.

Implementations

impl IndexStream

pub fn create( client: Arc<YahooFinanceClient>, index_symbols: Vec<String>, poll_interval: Duration, ) -> Pin<Box<dyn Stream<Item = Result<Vec<MarketIndex>, YahooError>> + Send>>

Create a new index stream that fetches index data at the specified interval.

Arguments

• client - The Yahoo Finance client to use for fetching data
• index_symbols - List of index symbols to track (e.g., “^GSPC”, “^DJI”, “^IXIC”)
• poll_interval - How often to fetch new data

Example

use finance_query_core::{IndexStream, YahooFinanceClient};
use std::time::Duration;
use futures_util::StreamExt;

// Stream S&P 500, Dow Jones, and NASDAQ
let symbols = vec!["^GSPC".to_string(), "^DJI".to_string(), "^IXIC".to_string()];
let stream = IndexStream::create(&client, symbols, Duration::from_secs(5));

while let Some(result) = stream.next().await {
    match result {
        Ok(indices) => {
            for index in indices {
                println!("{}: {} ({:+})", index.name, index.value, index.percent_change);
            }
        }
        Err(e) => eprintln!("Error: {}", e),
    }
}

pub fn with_default_interval( client: Arc<YahooFinanceClient>, index_symbols: Vec<String>, ) -> Pin<Box<dyn Stream<Item = Result<Vec<MarketIndex>, YahooError>> + Send>>

Create an index stream with a default 5-second interval.

pub fn us_major_indices( client: Arc<YahooFinanceClient>, poll_interval: Duration, ) -> Pin<Box<dyn Stream<Item = Result<Vec<MarketIndex>, YahooError>> + Send>>

Create a stream for major US indices (S&P 500, Dow Jones, NASDAQ).