Struct QuoteStream 

pub struct QuoteStream;

A stream that yields quote updates at regular intervals.

Implementations

impl QuoteStream

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

Create a new quote stream that fetches quotes for the given symbols at the specified interval.

Arguments

• client - The Yahoo Finance client to use for fetching quotes
• symbols - List of stock symbols to track
• poll_interval - How often to fetch new quotes

Example

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

let stream = QuoteStream::create(&client, vec!["AAPL", "GOOGL"], Duration::from_secs(5));

while let Some(result) = stream.next().await {
    match result {
        Ok(update) => println!("Got {} quotes", update.len()),
        Err(e) => eprintln!("Error: {}", e),
    }
}

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

Create a quote stream with a default 5-second interval.