Struct TradeStreamBuilder 

pub struct TradeStreamBuilder { /* private fields */ }

Builder for a TradeStream.

Implementations

impl TradeStreamBuilder

pub fn new() -> Self

Create a builder defaulting to US equities.

pub fn asset_class(self, class: AssetClass) -> Self

Choose the asset class (default: AssetClass::Stocks).

Forex and indices publish no per-trade prints; those classes are rejected at build.

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

Build and start the stream.

Errors

Returns StreamError::ConnectionFailed when the chosen asset class has no trade feed.

impl TradeStreamBuilder

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).

Trait Implementations

impl Default for TradeStreamBuilder

fn default() -> Self

Returns the “default value” for a type.