Struct PriceStreamBuilder 

pub struct PriceStreamBuilder { /* private fields */ }

Builder for creating price streams with custom configuration

Implementations

impl PriceStreamBuilder

pub fn new() -> Self

Create a new builder

pub fn source(self, source: PriceSource) -> Self

Choose the upstream backend (default: PriceSource::Yahoo).

Example

use finance_query::streaming::{AssetClass, PriceSource, PriceStreamBuilder};

let stream = PriceStreamBuilder::new()
    .symbols(["BTC-USD"])
    .source(PriceSource::Polygon(AssetClass::Crypto))
    .build()
    .await?;

pub fn symbols<S, I>(self, symbols: I) -> Self

where S: Into<String>, I: IntoIterator<Item = S>,

Add symbols to subscribe to

pub fn retry(self, delay: Duration) -> Self

Set the base delay before the first reconnection attempt (default: 3s). Later attempts grow exponentially from this, capped and jittered — see Self::max_reconnect_attempts to also cap how many attempts are made.

pub fn max_reconnect_attempts(self, max: u32) -> Self

Cap the number of consecutive reconnect attempts before the stream gives up and ends (default: unlimited, i.e. retry forever).

pub async fn build(self) -> StreamResult<PriceStream>

Build and start the price stream using the configured source.

Trait Implementations

impl Default for PriceStreamBuilder

fn default() -> Self

Returns the “default value” for a type.