Module streaming 

Real-time price streaming with pluggable provider backends.

This module provides a Stream-based API for receiving real-time price updates, similar to Kotlin Flow or Rx observables.

Overview

A StreamSource trait abstracts the provider-specific transport and wire protocol. Yahoo (YahooStreamSource) is the reference implementation, with additional providers (e.g. Polygon) supported through the same abstraction.

This module handles:

• Provider-agnostic reconnection logic
• Subscription management with automatic heartbeats
• Protobuf message decoding (Yahoo)
• A clean Stream API for consuming updates

Example

use finance_query::streaming::PriceStream;
use futures::StreamExt;

// Subscribe to symbols
let mut stream = PriceStream::subscribe(["AAPL", "NVDA", "TSLA"]).await?;

// Process updates as they arrive
while let Some(price) = stream.next().await {
    println!("{}: ${:.2} ({:+.2}%)",
        price.id,
        price.price,
        price.change_percent
    );
}

Structs

NewsStream

A continuous subscription to one or more RSS/Atom sources.

NewsStreamBuilder

Builder for creating a NewsStream with custom configuration.

PriceStream

A streaming price subscription that yields real-time price updates.

PriceStreamBuilder

Builder for creating price streams with custom configuration

PriceUpdate

Real-time price update from Yahoo Finance WebSocket.

Enums

MarketHoursType

Market hours type enumeration

OptionType

Option type enumeration

QuoteType

Quote type enumeration

StreamError

Errors that can occur during streaming

Type Aliases

StreamResult

Result type for streaming operations